时间戳

首页 > 解决方案 > 气流触发规则任务依赖

airflow - 气流触发规则任务依赖

问题描述

d在下面显示的 DAG 中，无论任务b&c是成功还是失败，我都想执行任务，但是对于任务eIf tasks b，c&d是成功的，那么只有它应该被触发。DAG 图像

写在下面的代码，但它不工作：

with DAG(dag_id='test_dag', default_args=args, schedule_interval=None) as dag:
   t_test = PythonOperator(task_id='test', python_callable=test)
   t_a = PythonOperator(task_id='a', python_callable=a)
   t_b = PythonOperator(task_id='b', python_callable=b)
   t_c = PythonOperator(task_id='c', python_callable=c)
   t_d = PythonOperator(task_id='d', python_callable=d, trigger_rule=TriggerRule.ALL_DONE)
   t_e = PythonOperator(task_id='e', python_callable=e, trigger_rule='all_success')
t_test >> t_a >> [t_b, t_c] >> t_d >> t_e

标签： airflow

解决方案

您需要在单独的语句中对工作流树的分支进行编码。

# execute task d no matter whether tasks b & c succeeded or failed
t_test >> t_a >> [t_b, t_c] >> t_d

# execute task e if tasks b, c & d succeeded

t_e << [t_b, t_c, t_d]

推荐阅读