1. 학습
  2. /
  3. 강의
  4. /
  5. Python으로 배우는 Apache Airflow 입문

Connected

연습 문제

Triggering a child Dag

You notice that some of your workflows are using similar components and realize you could separate out common tasks into their own Dag. This should allow you to run those components as necessary without maintaining multiple copies. You decide to execute a child Dag via a task within your current workflow.

The components dag, task, and datetime have been imported for you.

지침

100 XP
  • Import the operator needed to start a Dag from within your workflow.
  • Set the operator to trigger the Dag named child_pipeline.
  • Make sure the parent Dag waits for the triggered Dag to complete before continuing.
  • Set how frequently the operator checks whether the child Dag has finished.