HITLBranchOperator ile Dallanma
Bir şikâyet yönlendirme veri hattı, her talebi hangi ekibin ele alacağına bir insanın karar vermesi için HITLBranchOperator kullanır. Dag dağıtıldı — bir çalıştırma tetikle, bir dal seç ve geri kalanını Airflow'un nasıl yönettiğini gör.
Şu adımları izle:
- Dags görünümünde
complaint_router'ı etkinleştir ve bir çalıştırma tetikle. - En son çalıştırmayı aç ve
route_complaintgörevi deferred durumunu gösterene kadar bekle. - Required Actions sekmesinde Billing Issue'ı seç ve yanıtını gönder.
- Graph görünümüne geç ve her bir görevin durumuna bak.
"Billing Issue" seçildikten sonra, seçmediğin görevler ne olur?
Bu egzersiz, kursun bir parçasıdır
Airflow ile Veri İş Hatları Oluşturma
Uygulamalı etkileşimli egzersiz
Teoriyi etkileşime dönüştürün, interaktif egzersizlerimizden biriyle
Egzersize başla