运行具有不同间隔任务的 DAG

Question

我有 3 个任务，A、B 和 C。我只想运行任务 A 一次，然后每月运行任务 B，直到 end_date，然后运行任务C只清理一次。

这与此问题类似，但不适用。

感谢您的帮助

Answer 1

对于本应运行只有一次的任务A，您可以从here

中得到启发

就任务 B 和 C 而言，它们可以使用 ShortCircuitOperator 与 A 捆绑在一起（如您引用的中所述）

                   -> B
                 /
A -> ShortCircuit
                 \
                   -> C

或者，您可以使用 AirflowSkipException

在内部跳过 B 和 C

Run DAG with tasks of different interval