Branching met HITLBranchOperator

Een klachtverdelingspipeline gebruikt HITLBranchOperator zodat een mens kan kiezen welk team elk ticket afhandelt. De Dag is gedeployed — trigger een run, kies een branch en kijk hoe Airflow de rest afhandelt.

Volg deze stappen:

Activeer in de Dags-weergave complaint_router en trigger een run.
Open de laatste run en wacht tot de taak route_complaint de status deferred krijgt.
Kies in het tabblad Required Actions Billing Issue en dien je reactie in.
Schakel over naar de Graph-weergave en bekijk de status van elke taak.

Wat gebeurt er met de taken die je niet hebt geselecteerd nadat je "Billing Issue" hebt gekozen?

Deze oefening maakt deel uit van de cursus

Data-pijplijnen bouwen met Airflow

Bekijk cursus

Interactieve oefening met praktijkervaring

Zet theorie om in actie met een van onze interactieve oefeningen

Begin oefening