如果上一个 运行 到下一个时间表还没有完成,如何跳过下一个 DAG 时间表?

How to skip next schedule of DAG if previous run not yet finished by the time of next schedule?

我有一个案例可以跳过整个 运行 DAG,如果在即将到来的时间表之前,前一个尚未完成。有办法吗?

假设一个 DAG 需要每小时 运行 并且计划在上午 9 点 运行 到上午 10 点还没有完成,在我的例子中我想跳过上午 10 点 运行完全。

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

dag = DAG(
    ...,
    max_active_runs=1,
    catchup=False,
)