airflow - 触发规则 none_skipped 未按预期工作

Question

我有一种情况，我需要使用 none_skipped 触发规则，但它的行为很奇怪。这是我的场景。

分支任务 B，如果为真 T1 >> T2 >> joinTask 如果为假 F1 >> F2 >> joinTask

如果 B 中的条件为假，则跳过 T1，但执行 T2，因为触发规则为“all_done”（即使 T1 失败，我也需要 T2）。所以我把 T2 设为 'none_skipped'

如果 T1 成功或失败或上游失败，我期待 T2 被触发（根据文档）。相反，一旦 dag 开始，T2 就会被触发。它在任何其他任务之前执行。

标签： airflowairflow-scheduler

Answer 1

看起来这只是最近在气流 1.10.5 中修复的：

https://github.com/apache/airflow/pull/5902

尝试将气流更新到 1.10.5