airflow - 如何在 Airflow 中重新启动 DAG？

Question

由于数据库关闭，我的一个包含许多步骤的 DAG 中途停止。我想让 DAG 从它停止的地方开始，但我所能做的就是一项一项地开始 DAG 的各个任务。有没有办法根据已经完成的任务的成功告诉 Airflow 从它停止的地方启动 DAG？

这是一个示例，其中第一个任务已完成，其余任务已排队或没有状态:


当我单击单个任务 ( runme_1 ) 时，我可以重新启动它:


但是，如果我尝试启动一个没有满足依赖关系的任务(例如 run_after_loop )，我会看到以下错误消息:


我希望能够点击任何任务，要求它排队并让所有依赖项以正确的顺序运行。那可能吗？

我正在运行 Airflow 1.9.0。

Answer 1

听起来您需要从失败的任务开始 dag。

不要进入 DAG 并单击任务并单击运行，而是转到带有失败任务的 Dag 运行，单击失败的任务并单击清除。

清除任务将重新运行该任务，并且在该任务之后的任何其他任务都将运行。