astronomer avatar

Airflow Hitl

Adds approval gates, form inputs, and human-driven branching to Airflow DAGs using deferrable operators that release worker slots while waiting. You get ApprovalOperator for approve/reject flows, HITLBranchOperator for routing based on human choices, and HITLEntryOperator for pure form collection. The skill is built around a discover-then-code pattern: query the live Airflow registry for current constructor signatures before writing any tasks, since the provider changes params across releases. Responses come through the Airflow UI or REST API. Requires Airflow 3.1+. The safety checklist and external integration examples (Slack bots, custom scripts) are the most useful parts if you need humans in the loop without blocking workers.

skills.sh installs
980
GitHub stars
459
last updated
Aug 21, 2026

Install

$ npx -y skills add astronomer/agents --skill airflow-hitl --agent claude-code

Installs into .claude/skills of the current project.

Files

Airflow Human-in-the-Loop Operators

Pause a DAG until a human responds via the Airflow UI or REST API. HITL operators are deferrable — they release their worker slot while waiting.

Requires Airflow 3.1+ (af config version).

UI location: Browse → Required Actions. Respond from the task instance page's Required Actions tab.

Cross-references: migrating-ai-sdk-to-common-ai for AI/LLM task decorators; airflow for registry and API discovery commands used below.


Step 1 — Pick the capability you need

CapabilityClass (verify in Step 2)
Approve or reject; downstream skips on rejectApprovalOperator
Present N options and return which were chosenHITLOperator
Branch to one or more downstream tasks based on a choiceHITLBranchOperator
Collect a form (no approve/select step)HITLEntryOperator
Use the HITL trigger directly (advanced / custom operators)HITLTrigger

This is the only place class names are hardcoded. The provider adds, renames, and removes params across releases — do not copy parameter lists from memory. Fetch the current signature before writing code.


Sponsors

Details

Repository
github.com/astronomer/agents
Categories
AI & Agent Building, Productivity & Planning, Automation & Workflows
First seen
May 16, 2026

More from astronomer/agents

All 24
1microsoft avatarfile-test-bugmicrosoft/github-copilot-for-azureFile a GitHub issue for local integration test failures. TRIGGERS: file test bug, report test failure, create bug for test, integration test failed, test failur978skills.sh installs
2adobe avatarmigrationadobe/skillsMigrates legacy AEM (6.x, AMS, on-prem) to AEM as a Cloud Service using BPA CSV or cache, CAM/MCP target discovery, and a one-pattern-per-session workflow. Use 958skills.sh installs
3heygen-com avatarcreate-videoheygen-com/skillsCreate videos from a text prompt using HeyGen's Video Agent (POST /v3/video-agents). The default for most video requests — AI handles script, avatar, visuals, v945skills.sh installs
4alirezarezvani avatarsenior-ml-engineeralirezarezvani/claude-skillsML engineering skill for productionizing models, building MLOps pipelines, and integrating LLMs. Covers model deployment, feature stores, drift monitoring, RAG 940skills.sh installs
5vercel-labs avatarucpvercel-labs/agentic-commerce-skillsExpert-level implementation assistant for the Universal Commerce Protocol (UCP). Provides comprehensive tooling for adding UCP support to Next.js ecommerce code936skills.sh installs
6heygen-com avatarliveavatar-feedbackheygen-com/liveavatar-agent-skillsCollect and submit developer feedback to the LiveAvatar team. Use when: (1) A LiveAvatar integration is done, working, finished, or complete, (2) The user says 935skills.sh installs