Inizia subitoInizia gratis

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:

  1. Nella vista Dags, attiva complaint_router e avvia un run.
  2. Apri l'ultimo run e aspetta finché il task route_complaint mostra lo stato deferred.
  3. Nella scheda Required Actions, seleziona Billing Issue e invia la tua risposta.
  4. 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

Visualizza corso

esercizio interattivo pratico

Trasforma la teoria in pratica con uno dei nostri esercizi interattivi

Inizia esercizio