问题背景:
如何配置airflow的跨Dags依赖问题?...环境配置:
Python 3.8
Airflow 2.2.0
Airflow低版本中可能没有上述的两个Operators,建议使用2.0以后的版本。...start_date=datetime(2022, 1, 1), # 从指定日期开始执行
catchup=False,
tags=['test'],...trigger_dag_id='testB'
)
# 任务1,2依次执行,执行完成后通知dag testB 执行
t1 >> t2 >> t3
tastB: 子任务
from...start_date=datetime(2022, 1, 1), # 从指定日期开始执行
catchup=False,
tags=['test'],