目前 Airflow 不再支持 AwaitableTriggerDagRunOperator 操作符。相反,您可以使用 TriggerDagRunOperator 并设置其 wait_for_completion 参数为 True 来实现等待子 DAG 执行完成。以下是 Python 代码示例:
from airflow import DAG from airflow.operators.dagrun_operator import TriggerDagRunOperator from datetime import datetime
dag = DAG('parent_dag', schedule_interval='@daily', start_date=datetime(2022, 1, 1))
trigger = TriggerDagRunOperator( task_id='trigger_child_dag', trigger_dag_id='child_dag', dag=dag, wait_for_completion=True, )
trigger