如果在下一个计划时之前的运行尚未完成,如何跳过 DAG 的下一个计划?

Sas*_*adi 2 directed-acyclic-graphs airflow

如果到下一个计划时前一个尚未完成,我有一个案例可以跳过 DAG 的整个运行。有没有办法做到这一点?

想象一下,DAG 需要每小时运行一次,并且计划在上午 9 点运行在上午 10 点时尚未完成,在我的情况下,我想完全跳过上午 10 点运行。

Ela*_*lad 5

在 DAG 构造函数中设置max_active_runs=1&catchup=False

dag = DAG(
    ...,
    max_active_runs=1,
    catchup=False,
)
Run Code Online (Sandbox Code Playgroud)

  • @angelcervera 这就是追赶的意义。如果您发现存在明显行为的情况,请随时在项目中使用示例打开 GitHub 讨论,我们可以进一步讨论。请注意,我们始终改进文档和代码,因此您也可以通过向项目公开 PR 来帮助我们,以便为其他人改进它 (2认同)