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:
- În vizualizarea DAG-urilor, activează
complaint_routerși declanșează o rulare. - Deschide cea mai recentă rulare și așteaptă până când task-ul
route_complaintafișează starea deferred. - În fila Required Actions, selectează Billing Issue și trimite răspunsul.
- 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
Exercițiu interactiv practic
Transformă teoria în practică cu unul dintre exercițiile noastre interactive
Începe exercițiul