如何重新启动气流

Question

失败的任务我使用的是LocalExecutor和我的DAG有3任务其中任务（C）是依赖于任务（A）。任务（B）和任务（A）可以并行像运行下面

A - >ç

乙

所以任务（A）失败和，但任务（B）跑得很好。任务（C）在任​​务（A）失败时尚未运行。

我的问题是我该如何重新运行任务（A），因此任务（C）运行一旦任务（A）完成并且Airflow UI将其标记为成功。

Answer 1

在UI：

1. 转到DAG，并且要更改
2. 点击GraphView
3. 点击任务A
4. 点击 “清除”
运行的DAG运行

这将让任务A再次运行，如果成功，任务C应该运行。 这是有效的，因为当你清除一个任务的状态时，调度程序会将它视为它之前没有运行过这个DAG运行。