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

我使用的是LocalExecutor,我的dag有3个任务,其中任务(C)依赖于任务(A).任务(B)和任务(A)可以并行运行,如下所示

A – &以及c

所以任务(A)失败了,但任务(B)运行正常.任务(C)尚未运行,因为任务(A)失败.

我的问题是我如何单独运行任务(A),因此任务(A)运行一旦任务(A)完成,并且Airflow UI将它们标记为成功.

解决方法:

在UI中:

>转到dag,然后想要改变的跑步
>单击GraphView
>单击任务A.
>点击“清除”

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

上一篇:python – 为气流中的日志设置s3


下一篇:python – Apache Airflow调度程序不会在计划时触发DAG