HITLBranchOperator के साथ ब्रांचिंग
एक complaint-routing पाइपलाइन HITLBranchOperator का उपयोग करती है ताकि हर टिकट को संभालने वाली टीम इंसान चुन सके। Dag पहले से डिप्लॉय है — एक रन ट्रिगर करें, एक ब्रांच चुनें, और देखें कि बाकी काम Airflow कैसे संभालता है।
इन चरणों का पालन करें:
- Dags व्यू में
complaint_routerको सक्रिय करें और एक रन ट्रिगर करें। - नवीनतम रन खोलें और तब तक प्रतीक्षा करें जब तक
route_complaintटास्क की स्टेट deferred न हो जाए। - Required Actions टैब में, Billing Issue चुनें और अपना उत्तर सबमिट करें।
- Graph व्यू में स्विच करें और हर टास्क की स्टेट देखें।
"Billing Issue" चुनने के बाद, जिन टास्क को आपने नहीं चुना, उनके साथ क्या होता है?
यह अभ्यास पाठ्यक्रम का हिस्सा है
Airflow के साथ Data Pipelines बनाना
इंटरैक्टिव व्यावहारिक अभ्यास
हमारे इंटरैक्टिव अभ्यासों में से किसी एक के साथ सिद्धांत को व्यवहार में बदलें
अभ्यास शुरू करें