Пропустить запуск, если DAG уже запущен - PullRequest
0 голосов
/ 03 ноября 2019

У меня есть группа обеспечения доступности баз данных, которая мне нужна для запуска только одного экземпляра одновременно. Чтобы решить эту проблему, я использую max_active_runs = 1, который прекрасно работает:

dag_args = {
    'owner': 'Owner',
    'depends_on_past': False,
    'start_date': datetime(2018, 01, 1, 12, 00),
    'email_on_failure': False
}

sched = timedelta(hours=1)
dag = DAG(job_id, default_args=dag_args, schedule_interval=sched, max_active_runs=1)

Проблема заключается в следующем:

Когда DAG будет запущен и запущен экземпляр, AirFlow ожидает этого запускачтобы закончить, а затем снова вызывает DAG.

Мой вопрос:

Можно ли пропустить этот прогон, чтобы в этом случае DAG не запускался после этого выполнения?

Спасибо!

Добро пожаловать на сайт PullRequest, где вы можете задавать вопросы и получать ответы от других членов сообщества.
...