開始使用免費開始

使用 HITLBranchOperator 進行分支

有一個申訴分流的 pipeline 使用 HITLBranchOperator,讓人員決定每張工單要交由哪個團隊處理。Dag 已經部署完成——請觸發一次執行、選擇一個分支,然後看看 Airflow 如何處理後續步驟。

請依照以下步驟進行:

  1. 在 Dags 檢視中,啟用 complaint_router 並觸發一次執行。
  2. 開啟最新一次執行,等待 route_complaint 任務顯示為 deferred 狀態。
  3. Required Actions 分頁中,選擇 Billing Issue,並送出你的回覆。
  4. 切換到 Graph 檢視,查看各個任務的狀態。

選擇「Billing Issue」之後,對於你沒有選到的那些任務會發生什麼事?

本練習屬於課程

使用 Airflow 建置資料管線

檢視課程

動手互動練習

將理論付諸實踐,立即體驗我們的互動練習

開始練習