使用 HITLBranchOperator 实现分支
一个投诉分派管道使用 HITLBranchOperator,让人工选择由哪个团队处理每张工单。Dag 已部署——触发一次运行,选择一个分支,然后看看 Airflow 如何处理其余步骤。
请按以下步骤操作:
- 在 Dags 视图中,启用
complaint_router并触发一次运行。 - 打开最新的运行,等待
route_complaint任务显示为 deferred 状态。 - 在 Required Actions 选项卡中,选择 Billing Issue 并提交您的响应。
- 切换到 Graph 视图,查看每个任务的状态。
选择 "Billing Issue" 后,未被选择的任务会怎样?
本练习是课程的一部分
