Bắt đầu ngayBắt đầu miễn phí

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:

  1. Trong chế độ xem Dags, bật complaint_router và kích hoạt một lượt chạy.
  2. Mở lượt chạy mới nhất và đợi cho đến khi tác vụ route_complaint hiển thị trạng thái deferred.
  3. Trong tab Required Actions, chọn Billing Issue và gửi phản hồi của bạn.
  4. 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

Xem khóa học

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