python - airflow源码分析 - apache airflow教程



如何在Airflow上重新启动失败的任务 (1)

我正在使用LocalExecutor ,我的DAG3个任务 ,其中任务(C)依赖于任务(A)。 任务(B)和任务(A)可以并行运行,如下所示

A - >Ç

所以任务(A)失败了 ,但任务(B)运行良好 。 任务(C)在任​​务(A)失败时还没有运行。

我的问题是我如何重新运行任务(一),所以任务(C)运行一次任务(一)完成和气流用户界面标记为成功。


在UI中:

  1. 去DAG,DAG运行你想改变的运行
  2. 点击GraphView
  3. 点击任务A
  4. 点击“清除”

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





bigdata