airflow - 如何限制 Airflow 一次仅运行一个 DAG 实例？

Question

我希望 DAG 中的任务在下一次运行的第一个任务执行之前全部完成。
我有 max_active_runs = 1，但是 this仍然会发生。

default_args = {
    'depends_on_past': True,
    'wait_for_downstream': True,
    'max_active_runs': 1,
    'start_date': datetime(2018, 03, 04),
    'owner': 't.n',
    'email': ['t.n@example.com'],
    'email_on_failure': True,
    'email_on_retry': False,
    'retries': 3,
    'retry_delay': timedelta(minutes=4)
}

dag = DAG('example', default_args=default_args, schedule_interval = schedule_interval)

(我所有的任务都依赖于之前的任务。Airflow版本是1.8.0)
谢谢

Answer 1

我改把max_active_runs作为 DAG() 的参数而不是在 default_arguments ，它奏效了。

感谢 SimonD 给我这个想法，尽管在你的回答中没有直接指出它。