Acionando um Dag filho
Você percebe que alguns dos seus fluxos de trabalho usam componentes parecidos e conclui que pode separar tarefas comuns em um Dag próprio. Assim, você poderá executar esses componentes quando necessário, sem manter várias cópias. Você decide executar um Dag filho por meio de uma tarefa dentro do seu fluxo de trabalho atual.
Os componentes dag, task e datetime já foram importados para você.
Este exercicio faz parte do curso
Introdução ao Apache Airflow em Python
Instruções do exercicio
- Importe o operador necessário para iniciar um Dag de dentro do seu fluxo de trabalho.
- Defina o operador para acionar o Dag chamado
child_pipeline. - Garanta que o Dag pai aguarde o término do Dag acionado antes de continuar.
- Defina com que frequência o operador verifica se o Dag filho terminou.
exercicio interativo prático
Tente este exercicio completando este código de exemplo.
# Import TriggerDagRunOperator
from airflow.providers.standard.operators.trigger_dagrun import ____
@dag(start_date=datetime(2026, 1, 1))
def parent_orchestrator_dag():
# Trigger child_pipeline and wait for it to complete
trigger_child = TriggerDagRunOperator(
task_id="trigger_child_pipeline",
trigger_dag_id="____",
____=True,
____=30,
conf={"source": "s3://my-bucket/raw/"})
validate() >> trigger_child >> post_trigger_summary()
parent_orchestrator_dag()