Airflow 人工审批流程
原名:airflow-hitl
为 Airflow 3.1+ 工作流增加审批、表单和人工分支节点。
中文 Skills 技能说明
适合发布、付款、数据交付等必须由人确认的 DAG;先定义审批人、超时、拒绝和恢复路径,再实现并测试人工节点。Airflow、OpenLineage、dbt Core 和本地数据工具可在用户自己的环境使用;Astronomer 托管能力须使用自有合法账户,并确认中国大陆网络、区域、费用和数据位置。执行前读取真实项目、版本和官方资料,输出目标、依据、影响、验证结果与回退方式;没有证据时明确说明未知,不编造数据、配置或成功状态。 创建、修改、部署、发布、迁移、发送、删除或产生费用的操作,必须先展示目标和差异并获得有权限人员确认。 代码、数据库、日志、凭据、邮件、客户和企业资料按敏感内容处理,只读取任务所需范围,上传或外发前完成授权、脱敏和最小化。
上游能力依据
上游原始适用说明:Builds human-in-the-loop (HITL) Airflow workflows - approval gates, form input, and human-driven branching. Use when a DAG needs a human in the loop - an approval or reject step, sign-off before a task runs, a decision or approval UI, branching on a human choice, or collecting form input mid-run; also on mentions of ApprovalOperator, HITLOperator, HITLBranchOperator, HITLEntryOperator, or HITLTrigger. Requires Airflow 3.1+. Not for AI/LLM task calls (see migrating-ai-sdk-to-common-ai).
上游 SKILL.md 主要章节(保留原文标题):
- Step 1 — Pick the capability you need
- Step 2 — Discover the current signatures from the Airflow Registry
- Step 3 — Canonical example (approval gate)
- Step 4 — Behavior contracts (stable across versions)
- Timeout
- Markdown + Jinja in body
- Callbacks
- Notifiers
- Restricting who can respond
- Step 5 — Responding from external integrations
使用边界
先读取项目约定、依赖版本和现有测试,再提出最小改动。写文件、运行脚本、提交代码或发布前应检查差异并保留回退路径。
作者、翻译与许可证
- 原作者
- Astronomer 与 astronomer/agents contributors
- 中文翻译
- CEOFans翻译
- 许可证
- Apache-2.0
- 上游来源
- https://github.com/astronomer/agents/tree/dbd9bb79c4f7b7ac9c1cdd2b4b75213c81f423e5/skills/airflow-hitl
适用范围
平台:linux、macos、windows;标签:架构与规划、Airflow 人工审批流程
安全提示
基础静态扫描不等于绝对安全。技能可能调用命令、浏览器、云服务或本地文件,请在最小权限环境中使用,高风险操作必须人工确认。
如发现侵权、许可证或安全问题,可在本页前台提交投诉,管理员复核后可立即下架。