python - 如何在 Airflow 上重新启动失败的任务

Question

我正在使用 LocalExecutor，而我的 dag 有 3 个任务，其中 task(C) 依赖于 task(A)。 Task(B) 和 task(A) 可以像下面这样并行运行

A-->C

B

所以 task(A) 失败了，但 task(B) 运行良好。任务(C) 尚未运行，因为任务(A) 已失败。

我的问题是我如何单独重新运行 Task(A)，以便 Task(C) 在 Task(A) 完成并且 Airflow UI 将它们标记为成功后运行。

Answer 1

在用户界面中:

1. 转到要更改的运行的 dag 和 dag 运行
2. 点击GraphView
3. 点击任务A
4. 点击“清除”

这会让任务 A 再次运行，如果成功，任务 C 应该运行。这很有效，因为当您清除任务的状态时，调度程序会将其视为之前没有运行过此 dag 运行。