我使用的是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运行.