Sas*_*adi 2 directed-acyclic-graphs airflow
如果到下一个计划时前一个尚未完成,我有一个案例可以跳过 DAG 的整个运行。有没有办法做到这一点?
想象一下,DAG 需要每小时运行一次,并且计划在上午 9 点运行在上午 10 点时尚未完成,在我的情况下,我想完全跳过上午 10 点运行。
在 DAG 构造函数中设置max_active_runs=1&catchup=False
dag = DAG(
...,
max_active_runs=1,
catchup=False,
)
Run Code Online (Sandbox Code Playgroud)
| 归档时间: |
|
| 查看次数: |
4479 次 |
| 最近记录: |