
Airflow
Wraps the Airflow 3.x REST API with read-heavy defaults and optional write operations behind an env flag. You get seven tools to list DAGs, pull runs and task instances, tail logs, and trigger or clear tasks when AIRFLOW_ALLOW_WRITE is true. Auth is handled via SimpleAuthManager JWT that the server mints and refreshes transparently from username and password. Ships with two prompts for failure triage and schedule audits, plus a dag-health-rollup aggregation that replaces the usual list-then-fetch dance. Reach for this when you're debugging pipelines in Claude and want to skip the Airflow UI. Airflow 2.x is not supported; the server expects /api/v2 and the auth changes that shipped in 3.0.
- GitHub stars
- 2
- tools
- 8
- auth
- Secret needed
- transport
- STDIO
- env vars
- 6
- last updated
- Jun 19, 2026
Tools
8 toolsPublic tool metadata for what this MCP can expose to an agent.
airflow-list-dagsList active DAGs with tag/search filters
List active DAGs with tag/search filters
No parameter schema in public metadata yet.
airflow-list-runsRecent runs of one DAG (state filter, ordered newest first)
Recent runs of one DAG (state filter, ordered newest first)
No parameter schema in public metadata yet.
airflow-get-task-instancesTask instances for a specific DAG run
Task instances for a specific DAG run
No parameter schema in public metadata yet.
airflow-get-task-logsTail (last N kB) of one task instance log
Tail (last N kB) of one task instance log
No parameter schema in public metadata yet.
airflow-trigger-dagTrigger a new run (write-gated)
Trigger a new run (write-gated)
No parameter schema in public metadata yet.
airflow-clear-taskClear specific task instances → re-run (write-gated)
Clear specific task instances → re-run (write-gated)
No parameter schema in public metadata yet.
dag-health-rollupAggregated DAG health: success rate + avg duration + last failed run + failing tasks
Aggregated DAG health: success rate + avg duration + last failed run + failing tasks
No parameter schema in public metadata yet.
search-toolsNatural-language tool discovery
Natural-language tool discovery
No parameter schema in public metadata yet.
Sponsors
Configuration
AIRFLOW_API_URL*Airflow host base, e.g. 'http://airflow.example.com:8080'. Server prepends /api/v2 internally; trailing /api/v1 or /api/v2 is stripped if supplied.
AIRFLOW_USERNAME*Airflow username (used to mint a JWT via SimpleAuthManager /auth/token).
AIRFLOW_PASSWORD*secretAirflow password (used to mint a JWT via SimpleAuthManager /auth/token).
AIRFLOW_ALLOW_WRITEdefault: falseSet to 'true' to enable trigger-dag and clear-task tools. Default read-only.
AIRFLOW_TOOLSComma-separated category allowlist (airflow,meta).
AIRFLOW_DISABLEComma-separated category disablelist.
Readme
@us-all/airflow-mcp
Airflow MCP server — read DAGs, runs, task instances, log tails; trigger and clear (write-gated). Built on
@us-all/mcp-toolkit.
A focused MCP for the Airflow 3.x REST API (/api/v2). Read by default; airflow-trigger-dag and airflow-clear-task are gated behind AIRFLOW_ALLOW_WRITE=true. Auth is JWT via SimpleAuthManager — supply AIRFLOW_USERNAME + AIRFLOW_PASSWORD and the server mints/refreshes the token transparently.
For deeper dbt integration (manifest parsing, run-results history, source freshness, per-column test coverage, lineage walks, custom DQ result tables), install the companion @us-all/dbt-mcp alongside.
- 7 tools in
airflow+metacategories - 2 MCP Prompts for DAG triage workflows
- 1 aggregation tool that replaces the list-runs → get-task-instances combo
Install
pnpm add -D @us-all/airflow-mcp
Run
AIRFLOW_API_URL=http://airflow.example.com:8080 \
AIRFLOW_USERNAME=admin AIRFLOW_PASSWORD=... \
npx @us-all/airflow-mcp
Details
- Repository
- github.com/us-all/airflow-mcp-server
- Categories
- Automation & Workflows, Productivity & Office
- Package
@us-all/airflow-mcp- Transport
- STDIO
- Auth
- Required
- Registry
- MCP registry, active