Меня интересует использование параметра при ручном запуске дага с помощью https://airflow.apache.org/docs/apache-airflow/stable/dag-run.html#passing-parameters-when-triggering-dags.
В моем случае аргумент будет days_of_data, и он должен быть равен 7, если мы не передаем аргумент как JSON при ручном запуске. Таким образом, мы могли бы вручную активировать dag, и если бы параметр не был передан, его значение в любом случае было бы равно 7.
Во-первых, убедитесь, что аргумент days_of_data является шаблонным полем в вызываемом вами операторе. После этого вам просто нужно установить значение по умолчанию в операторе следующим образом:
"{{ dag_run.conf['days_of_data'] or 7 }}"
Это установит days_of_data
как 7, если вы не передадите следующий JSON при выполнении DAG вручную (либо из CLI, либо из пользовательского интерфейса):
{"days_of_data": days}
Где х может быть любым значением. Обратите внимание, что этот параметр будет строкой, поэтому вам может потребоваться преобразовать его в int или другой тип перед его использованием.