使用 HITLBranchOperator 進行分支
有一個申訴分流的 pipeline 使用 HITLBranchOperator,讓人員決定每張工單要交由哪個團隊處理。Dag 已經部署完成——請觸發一次執行、選擇一個分支,然後看看 Airflow 如何處理後續步驟。
請依照以下步驟進行:
- 在 Dags 檢視中,啟用
complaint_router並觸發一次執行。 - 開啟最新一次執行,等待
route_complaint任務顯示為 deferred 狀態。 - 在 Required Actions 分頁中,選擇 Billing Issue,並送出你的回覆。
- 切換到 Graph 檢視,查看各個任務的狀態。
選擇「Billing Issue」之後,對於你沒有選到的那些任務會發生什麼事?
本練習屬於課程
