可以通过在DAG定义中传递参数"wait_for_downstream",以便在运行子DAG时等待所有任务完成。这将确保Airflow在遍历DAG时不会跳过任何任务。 示例代码如下:
subdag = SubDagOperator(
task_id='subdag_task',
subdag=my_subdag(dag_name='parent_dag', default_args=default_args),
dag=dag,
wait_for_downstream=True # 添加此参数以等待子DAG的所有任务完成
)