Ramificazione con HITLBranchOperator
Una pipeline di smistamento dei reclami usa HITLBranchOperator per permettere a una persona di scegliere quale team gestisce ciascun ticket. La Dag è distribuita: avvia un run, scegli un branch e guarda come Airflow gestisce il resto.
Segui questi passaggi:
- Nella vista Dags, attiva
complaint_routere avvia un run. - Apri l'ultimo run e aspetta finché il task
route_complaintmostra lo stato deferred. - Nella scheda Required Actions, seleziona Billing Issue e invia la tua risposta.
- Passa alla vista Graph e osserva lo stato di ciascun task.
Dopo aver selezionato "Billing Issue", cosa succede ai task che non hai selezionato?
Questo esercizio fa parte del corso
Creare data pipeline con Airflow
esercizio interattivo pratico
Trasforma la teoria in pratica con uno dei nostri esercizi interattivi
Inizia esercizio