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

how to restart dag and tasks in airflow even they were succeed.

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

我做了一个 dag 和 运行 dag 的一个实例。今天有5个任务。前四个任务成功,但最后一个任务失败。所以我对这些任务进行了更改。我希望这5个任务可以重新运行一遍。但是前四个任务永远不会重新运行。 airflow 做了一些不需要的事情,直接 运行 最后一个任务,并假装它有 re运行 前四个任务。即使我在前四个任务中也做了很多改变。 有没有人可以帮助我?

您需要清空DAG 运行:点击上方绿色圆圈,点击清空按钮,确认清空任务。