ÎncepețiÎncepe gratuit

Ramificație cu HITLBranchOperator

Un pipeline de rutare a reclamațiilor folosește HITLBranchOperator pentru a lăsa un operator uman să aleagă care echipă se ocupă de fiecare ticket. DAG-ul este implementat — declanșează o rulare, alege o ramură și observă cum gestionează Airflow restul procesului.

Urmează acești pași:

  1. În vizualizarea DAG-urilor, activează complaint_router și declanșează o rulare.
  2. Deschide cea mai recentă rulare și așteaptă până când task-ul route_complaint afișează starea deferred.
  3. În fila Required Actions, selectează Billing Issue și trimite răspunsul.
  4. Treci la vizualizarea Graph și verifică starea fiecărui task.

După ce selectezi „Billing Issue", ce se întâmplă cu task-urile pe care nu le-ai selectat?

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