开始使用免费开始使用

使用 HITLBranchOperator 实现分支

一个投诉分派管道使用 HITLBranchOperator,让人工选择由哪个团队处理每张工单。Dag 已部署——触发一次运行,选择一个分支,然后看看 Airflow 如何处理其余步骤。

请按以下步骤操作:

  1. 在 Dags 视图中,启用 complaint_router 并触发一次运行。
  2. 打开最新的运行,等待 route_complaint 任务显示为 deferred 状态。
  3. Required Actions 选项卡中,选择 Billing Issue 并提交您的响应。
  4. 切换到 Graph 视图,查看每个任务的状态。

选择 "Billing Issue" 后,未被选择的任务会怎样?

本练习是课程的一部分

使用 Airflow 构建数据流水线

查看课程

动手互动练习

通过我们的互动练习之一,将理论转化为实践

开始练习