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 exercício faz parte do curso
Introdução ao Apache Airflow em Python
Instruções do exercício
- 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.
Exercício interativo prático
Experimente este exercício 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()