Rẽ nhánh với HITLBranchOperator
Một pipeline định tuyến khiếu nại sử dụng HITLBranchOperator để cho phép con người chọn đội nào xử lý từng phiếu. Dag đã được triển khai — hãy kích hoạt một lượt chạy, chọn một nhánh và xem Airflow xử lý phần còn lại như thế nào.
Làm theo các bước sau:
- Trong chế độ xem Dags, bật
complaint_routervà kích hoạt một lượt chạy. - Mở lượt chạy mới nhất và đợi cho đến khi tác vụ
route_complainthiển thị trạng thái deferred. - Trong tab Required Actions, chọn Billing Issue và gửi phản hồi của bạn.
- Chuyển sang chế độ xem Graph và xem trạng thái của từng tác vụ.
Sau khi chọn "Billing Issue", điều gì xảy ra với các tác vụ bạn không chọn?
Bài tập này là một phần của khóa học
Xây dựng Data Pipeline với Airflow
Bài tập tương tác thực hành
Biến lý thuyết thành hành động với một trong các bài tập tương tác của chúng tôi
Bắt đầu bài tập