1. Learn
    2. /
  2. Cursuri
    3. /
  3. Introducere în Apache Airflow în Python
Connected

exercițiu

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.

Instrucțiuni

100 XP
  • 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.