由于数据库关闭,我的一个有许多步骤的 DAG 中途停止了。我想让 DAG 从它停止的地方开始,但我所能做的就是一个接一个地启动 DAG 的各个任务。有没有办法根据已经完成的任务的成功来告诉 Airflow 从它停止的地方启动 DAG?
这是一个示例,其中第一个任务已完成,其余任务已排队或没有状态:
当我单击单个任务 ( runme_1
) 时,我可以重新启动它:
但是,如果我尝试启动尚未满足其依赖关系的任务(例如run_after_loop
),我会看到以下错误消息:
我希望能够单击任何任务,要求它排队并让所有依赖项以正确的顺序运行。那可能吗?
我正在运行 Airflow 1.9.0。