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:
- W widoku Dags aktywuj
complaint_routeri uruchom DAG. - Otwórz ostatnie uruchomienie i poczekaj, aż zadanie
route_complaintprzejdzie w stan deferred. - Na karcie Required Actions wybierz Billing Issue i prześlij odpowiedź.
- 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
Interaktywne ćwiczenie praktyczne
Przekształć teorię w praktykę dzięki jednemu z naszych interaktywnych ćwiczeń
Rozpocznij ćwiczenie