ÎncepețiÎncepe gratuit

Declanșarea unui pipeline din CLI

De cele mai multe ori, planificatorul rulează DAG-ul în locul tău, dar uneori trebuie să îl pornești manual – pentru o dată specifică sau o reprocesare rapidă. DAG-ul daily_sales_load este deja activ, iar planificatorul a produs o rulare scheduled. Vei declanșa o a doua rulare din CLI și vei compara cum etichetează Airflow fiecare rulare.

  1. Rulează airflow dags trigger daily_sales_load --logical-date 2026-04-20 în terminal pentru a declanșa o rulare pentru o dată specifică.
  2. Așteaptă aproximativ 30 de secunde până când rularea manuală se finalizează.
  3. Rulează airflow dags list-runs daily_sales_load pentru a vedea toate rulările.

După ce rulezi airflow dags list-runs, vei vedea două rulări. Uită-te la coloana run_id. Cu ce prefix începe rularea declanșată manual?

Acest exercițiu face parte din cursul

Construirea pipeline-urilor de date cu Airflow

Vezi cursul

Exercițiu interactiv practic

Transformă teoria în practică cu unul dintre exercițiile noastre interactive

Începe exercițiul