Een child-Dag triggeren

Je merkt dat sommige van je workflows vergelijkbare componenten gebruiken en beseft dat je algemene taken kunt opsplitsen in een eigen Dag. Zo kun je die componenten naar behoefte uitvoeren zonder meerdere kopieën te onderhouden. Je besluit een child-Dag uit te voeren via een taak binnen je huidige workflow.

De componenten dag, task en datetime zijn al voor je geïmporteerd.

Deze oefening maakt deel uit van de cursus

Introductie tot Apache Airflow in Python

Cursus bekijken

Oefeninstructies

Importeer de operator die nodig is om een Dag vanuit je workflow te starten.
Stel de operator in om de Dag met de naam child_pipeline te triggeren.
Zorg dat de parent-Dag wacht tot de getriggerde Dag klaar is voordat hij doorgaat.
Stel in hoe vaak de operator controleert of de child-Dag is voltooid.

Praktische interactieve oefening

Probeer deze oefening eens door deze voorbeeldcode in te vullen.

# 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()

Code bewerken en uitvoeren