Zacznij terazZacznij za darmo

Rozgałęzianie z HITLBranchOperator

Potok do obsługi reklamacji używa HITLBranchOperator, żeby człowiek mógł zdecydować, który zespół zajmie się danym zgłoszeniem. DAG jest już wdrożony — uruchom go, wybierz gałąź i sprawdź, jak Airflow poradzi sobie z resztą.

Wykonaj kolejne kroki:

  1. W widoku Dags aktywuj complaint_router i uruchom DAG.
  2. Otwórz ostatnie uruchomienie i poczekaj, aż zadanie route_complaint przejdzie w stan deferred.
  3. Na karcie Required Actions wybierz Billing Issue i prześlij odpowiedź.
  4. Przełącz się na widok Graph i sprawdź stan każdego zadania.

Co dzieje się z zadaniami, których nie wybrałeś po zaznaczeniu „Billing Issue"?

To ćwiczenie jest częścią kursu

Budowanie potoków danych z Airflow

Zobacz kurs

Interaktywne ćwiczenie praktyczne

Przekształć teorię w praktykę dzięki jednemu z naszych interaktywnych ćwiczeń

Rozpocznij ćwiczenie