1. Learn
    2. /
  2. 课程
    3. /
  3. Python 中的 Apache Airflow 入门
Connected

道练习

触发子 Dag

您注意到部分工作流使用了相似的组件，于是想到可以把通用任务拆分到各自的 Dag 中。这样就能在需要时独立运行这些组件，而无需维护多份拷贝。您决定在当前工作流中的某个任务里执行一个子 Dag。

dag、task 和 datetime 已为您导入。

说明

100 XP
  • 导入可在工作流内启动 Dag 的 operator。
  • 将该 operator 配置为触发名为 child_pipeline 的 Dag。
  • 确保父 Dag 在继续之前会等待被触发的 Dag 完成。
  • 设置该 operator 检查子 Dag 是否完成的频率。