Branching mit HITLBranchOperator
Eine Pipeline zum Weiterleiten von Beschwerden nutzt den HITLBranchOperator, damit eine Person auswählen kann, welches Team jedes Ticket bearbeitet. Der Dag ist bereitgestellt – löse einen Lauf aus, wähle einen Branch und sieh zu, wie Airflow den Rest übernimmt.
Gehe so vor:
- Aktiviere in der Dags-Ansicht
complaint_routerund starte einen Lauf. - Öffne den neuesten Lauf und warte, bis der Task
route_complaintden Zustand deferred anzeigt. - Wähle im Tab Required Actions Billing Issue aus und sende deine Antwort.
- Wechsle zur Graph-Ansicht und sieh dir den Zustand der einzelnen Tasks an.
Was passiert nach der Auswahl von "Billing Issue" mit den Tasks, die du nicht ausgewählt hast?
Diese Übung ist Teil des Kurses
<Kurs>Data-Pipelines mit Airflow aufbauen</Kurs>Interaktive praktische Übung
Verwandle Theorie mit einer unserer interaktiven Übungen in die Praxis
Übung starten