Declanșarea unui DAG copil

Observi că unele dintre fluxurile tale de lucru folosesc componente similare și îți dai seama că ai putea separa sarcinile comune în propriul lor DAG. Astfel, vei putea rula acele componente ori de câte ori este nevoie, fără să menții mai multe copii. Decizi să execuți un DAG copil printr-o sarcină din fluxul tău de lucru curent.

Componentele dag, task și datetime au fost deja importate pentru tine.

Acest exercițiu face parte din cursul

Introducere în Apache Airflow în Python

Vezi cursul

Instrucțiuni pentru exercițiu

Importă operatorul necesar pentru a porni un DAG din cadrul fluxului tău de lucru.
Configurează operatorul să declanșeze DAG-ul numit child_pipeline.
Asigură-te că DAG-ul părinte așteaptă finalizarea DAG-ului declanșat înainte de a continua.
Setează cât de frecvent verifică operatorul dacă DAG-ul copil s-a finalizat.

Exercițiu interactiv practic

Încearcă acest exercițiu completând acest cod de exemplu.

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

Editează și rulează codul