Förgrening med HITLBranchOperator
En pipeline för klagomålshantering använder HITLBranchOperator för att låta en människa välja vilket team som hanterar varje ärende. DAG:en är driftsatt – trigga en körning, välj en gren och se hur Airflow hanterar resten.
Foll dessa steg:
- Aktivera
complaint_routeri Dags-vyn och trigga en körning. - Öppna den senaste körningen och vänta tills uppgiften
route_complaintvisar tillståndet deferred. - Välj Billing Issue på fliken Required Actions och skicka in ditt svar.
- Växla till Graph-vyn och granska tillståndet för varje uppgift.
Vad händer med de uppgifter du inte valde efter att ha valt "Billing Issue"?
Den här övningen är en del av kursen
Bygg datapipelines med Airflow
Interaktiv övning med praktiskt arbete
Gör teori till handling med en av våra interaktiva övningar
Starta övningen