airflow - 如果未触发某些直接上游，则气流运行任务

Question

我有一个 DAG，它有 5 个任务 A、B、C、D、E。以及由上述失败任务触发的 5 个任务，A_f、B_f、C_f、D_f 和 E_f 各一个（成功时同样五个）。最后是任务 X，它将失败结果写入数据库。可以说，如果前五个任务中有两个失败（A 和 D），则只有 A_f 和 D_f 被触发。我可以做些什么来运行任务 X？all_done 会起作用吗？即使某些上游任务从未被触发？我不太确定。

标签： airflow

Answer 1

是all_done的应该工作。只要任务 X 的上游任务的状态None都不是设置为upstream failed)，则all_done触发器将起作用。