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了解更多选项
我一天有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了解更多选项