python - 仅运行下游任务而不是当前任务 - 气流

Question

我有一个AirflowDAG，它作为一项upstream任务和大约 40 个downstream任务upstream（如 1 到 40 个映射）。一个成功完成，由于upstream某种原因我不得不停止downstream任务。现在我想执行所有这些。有没有办法通过只执行一个命令（而不是清除下游的每个单独的命令）来做到这一点？不管是来自 Web UI 还是来自终端。

标签： pythonairflow

Answer 1

如果要同时重新执行所有下游任务，请单击 DAG UI 中的 1 个上游任务并调出它的任务 UI。按“下游”、“清除”，并确认您要清除所有选定的任务。一旦执行完毕，将 1 个上游任务标记为成功。然后所有下游任务将忘记其先前的状态并重新执行。