我使用的是localexecutor，我的dag有3个任务，其中任务（c）依赖于任务（a）。任务（b）和任务（a）可以并行运行，如下所示a-->cb所以任务（a）失败了，但任务（b）运行良好。任务（c）尚未运行，因为任务（a）已失败。我的问题是如何单独重新运行task（a），以便task（c）在task（a）完成并将其标记为成功后运行。
o2g1uqev1#
在ui中：转到dag，然后转到要更改的运行的dag运行单击graphview单击任务a点击“清除”这将让任务a再次运行，如果成功，任务c应该运行。这是因为当您清除任务的状态时，调度程序会将其视为之前没有运行过的dag运行。
1条答案
按热度按时间o2g1uqev1#
在ui中：
转到dag，然后转到要更改的运行的dag运行
单击graphview
单击任务a
点击“清除”
这将让任务a再次运行，如果成功，任务c应该运行。这是因为当您清除任务的状态时，调度程序会将其视为之前没有运行过的dag运行。