如何重新启动气流中的dag和任务,即使它们成功了。

vit*_*yan 4 task directed-acyclic-graphs airflow

我试图重新启动整个dag和任务,即使它们成功了。

我做了一个dag并运行了一个dag实例。这一天有5个任务。前四个任务成功,但最后一个任务失败。因此我对这些任务进行了更改。我希望这5个任务可以重新运行。但是前四个任务永远不会重新运行。气流做一些不需要的事情,直接运行最后一个任务,并假装它重新运行了前四个任务。即使我在前四个任务中做了很多更改。有没有人可以帮助我? 在此处输入图片说明

Ser*_*kov 5

您需要清除DAG运行:单击顶部的绿色圆圈,然后单击“清除”按钮,然后确认清除任务。