Параметр командной строки для активации DAG воздушного потока

У нас есть конвейер непрерывной интеграции, который автоматически развертывает наши DAG Airflow на сервере Airflow. При развертывании новой версии группы обеспечения доступности баз данных ее состояние по умолчанию ВЫКЛ. Мы хотели бы включить его ВКЛ как часть задач, выполняемых процессом развертывания.

Есть ли параметр командной строки в Airflow, который позволяет включить DAG? Спасибо


command-line continuous-integration airflow apache-airflow
person Alexis.Rolland    schedule 22.11.2017    source источник

Ответы (2)


arrow_upward
9
arrow_downward

Хорошо, кажется, я не смотрел достаточно внимательно. Ответ находится здесь, в документации Airflow.

Вы можете отключить DAG OFF с помощью следующей команды:

$ airflow pause <dag_id>

Вы можете включить DAG ON с помощью следующей команды:

$ airflow unpause <dag_id>
person Alexis.Rolland    schedule 22.11.2017

arrow_upward
3
arrow_downward

Когда вы говорите «новая версия», я предполагаю, что вы изменили DAG_ID, не думали ли вы обновить airflow.cfg до dags_are_paused_at_creation = False?

person Chengzhi    schedule 22.11.2017
comment
Да, ваше предположение верно. Под новой версией DAG я подразумеваю обновление существующего dag_id. Предлагаемое вами решение действительно могло бы быть вариантом, но в моем случае у меня нет доступа к airflow.cfg, и, поскольку это общий экземпляр Airflow, другие пользователи могут не захотеть изменять настройку «dags_are_paused_at_creation». Кстати, знаете ли вы, действительно ли создание версий DAG считается созданием? Спасибо - person Alexis.Rolland; 24.11.2017