Airflow 任务 运行 无论下游发生什么

Airflow task run no matter what happen to downstream

我一天有3个任务。

任务 A 运行 首先。如果任务 A 成功,则任务 B 运行s。

我的任务 C 在任务 B 之后有 运行,但它不依赖于任务 B 或任务 A 的成功或失败。

无论任务 A 和 B 发生什么,任务 C 都需要。但是,它需要在任务 A 和 B 完成后运行。

有什么想法吗?

要在其他任务完成后执行任务 运行,但不管它们的执行结果如何,请将 trigger_rule 参数设置为 all_done,如下所示:

my_task = MyOperator(task_id='my_task',
                     trigger_rule='all_done'

查看trigger rule documentation了解更多选项