SuperAPI AI 工具集

airflow-hitl

办公与效率

查看项目

更新于 10-16 01:35

技能介绍

用途:在 Airflow DAG 中实现人在回路工作流,包括人工审批/拒绝、表单输入和人工驱动的分支。所有 HITL 操作符均为可延迟(deferrable)操作符,等待人工响应时释放 worker 槽位,应优先使用它们而非自定义 sensor 或轮询循环。

主要能力与操作符:ApprovalOperator 提供批准或拒绝,拒绝会使下游任务被跳过(审批任务本身成功);HITLOperator 选择选项并填写表单,返回所选内容;HITLBranchOperator 选择下游任务,运行所选、跳过其余;HITLEntryOperator 提交表单并返回表单数据。

使用方式:从 airflow.providers.standard.operators.hitl 导入相应操作符,在 DAG 中实例化并设置 subject、options、params 等参数,通过 output 将结果传给下游任务。响应位置在 Airflow UI 的 Browse -> Required Actions,或通过任务实例的 Required Actions 标签页及 REST API 响应。

可选功能:支持 Notifier 通知(可生成 UI 链接);可通过 respondents 限制响应人,格式取决于认证管理器(SimpleAuthManager 用用户名、FabAuthManager 用邮箱、Astro 用 Astro ID);可用 execution_timeout 设置超时,并用 defaults 指定超时时的默认选择。

限制:需要 Airflow 3.1+,Airflow 2.x 不可用。其余细节资料未提供。