У меня есть группа обеспечения доступности баз данных, которая мне нужна для запуска только одного экземпляра одновременно. Чтобы решить эту проблему, я использую 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 не запускался после этого выполнения?
Спасибо!