airflow-dev-mcp
This server lets an AI coding assistant drive a development or local Apache Airflow cluster through Airflow's REST API, enabling the full write-a-DAG / run-it / read-the-logs development loop.
DAG Management
list_dags— List registered DAGs with their paused/active/import-error flags, file locations, tags, and scheduling info; filter by pattern or tagsset_dag_paused— Pause or unpause a DAG (new local DAGs start paused by default, blocking execution)get_import_errors— Retrieve DAG parse failures with filenames and full tracebacks — the primary tool for diagnosing why a new DAG isn't showing up
DAG Run Operations
trigger_dag— Manually start a DAG run, optionally with aconfpayload, logical date, and a note; returns thedag_run_idlist_dag_runs— List recent runs for a given DAG or across all DAGs, filterable by stateget_run_status— Get the state of a DAG run plus per-task states (task ID, state, try number, operator, timing, duration)
Task Operations
get_task_logs— Fetch logs for a specific task instance attempt, withtry_number,map_index, andtail_linesoptionsclear_task_instances— Clear task instances for re-execution after a fix; supports dry-run preview, scoped clearing, and resetting DAG run state
Configuration Inspection (Read-Only)
list_variables— Read Airflow Variables (sensitive values masked; no create/modify)list_connections— Read Airflow Connection metadata (passwords never returned; no create/modify)
Supports both Airflow 3 (default) and Airflow 2 via configurable API prefix and auth mode.
Click on "Install Server".
Wait a few minutes for the server to deploy. Once ready, it will show a "Started" state.
In the chat, type
@followed by the MCP server name and your instructions, e.g., "@airflow-dev-mcpTrigger the my_etl DAG and check its status"
That's it! The server will respond to your query, and you can continue using it as needed.
Here is a step-by-step guide with screenshots.
airflow-dev-mcp
An MCP server that lets an AI coding assistant (Claude Code, Cursor, and other MCP clients) drive a development or local Airflow cluster through Airflow's REST API. It can trigger DAG runs, watch their status, read task logs, and diagnose parse errors.
It talks to Airflow over HTTP only. There's no dependency on your Airflow source tree,
no filesystem or database access, and no local config files. All configuration is set through environment
variables. It support both Airflow 3 (via /api/v2, the default) and
Airflow 2 (/api/v1).
Airflow-dev-mcp is designed for the write-a-DAG / run-it / read-the-logs loop against a development and/or local environment. Pointing it at a production cluster is not recommended.
Install & run
The package ships a single console command, airflow-dev-mcp, which starts the MCP
server on stdio. Installation requires uv.
_Note: most users will skip this and just add it to their coding environment (See: below)
To download and validate the package, run:
uvx airflow-dev-mcp --check # fetch + run a one-shot connectivity checkIt can be installed as a persistent tool but typical installation is to
just have your coding agent call it through uvx (See: Configure your
MCP client below). If you do want to install it system wide, use one of the
two following commands
uv tool install airflow-dev-mcp
# or
pipx install airflow-dev-mcpRelated MCP server: astro-airflow-mcp
Configure your MCP client
Claude Code
The easiest way is the claude mcp add CLI, which writes the config to the correct
place for you. From your project directory:
claude mcp add airflow-dev \
-e AIRFLOW_URL=http://localhost:8080 \
-e AIRFLOW_USERNAME=admin \
-e AIRFLOW_PASSWORD=admin \
-- uvx airflow-dev-mcpAdd --scope user to make it available in every project, or --scope project to write
a checked-in .mcp.json you can commit for your team (the default scope is local to you
in the current project).
To configure it by hand instead, create a .mcp.json file in the project root — this
is the file Claude Code reads for project-scoped MCP servers.
{
"mcpServers": {
"airflow-dev": {
"command": "uvx",
"args": ["airflow-dev-mcp"],
"env": {
"AIRFLOW_URL": "http://localhost:8080",
"AIRFLOW_USERNAME": "admin",
"AIRFLOW_PASSWORD": "admin"
}
}
}
}For a user-global setup, put the same mcpServers block in ~/.claude.json instead.
Other MCP clients
Any client that launches stdio MCP servers works the same way: run the command
airflow-dev-mcp (or uvx airflow-dev-mcp) with the environment variables below.
Configuration
All configuration is via environment variables:
Variable | Default | Description |
|
| Base URL of the cluster, no path. |
|
| API path prefix. Use |
| — | Username. Used together with |
| — | Password. |
| — | Explicit bearer token; skips username/password entirely. |
|
|
|
|
| Path used to exchange credentials for a JWT. |
|
| HTTP timeout, in seconds. |
|
| Set |
Authentication
Airflow 3.x (the default local/MWAA-style image): leave
AIRFLOW_AUTH_MODE=auto. The server posts your username/password to/auth/token, caches the returned JWT, and sends it as a bearer token on every request.Airflow 2.x: set
AIRFLOW_API_PREFIX=/api/v1andAIRFLOW_AUTH_MODE=basic(2.x uses HTTP basic auth against the REST API).Pre-issued token: set
AIRFLOW_TOKENand omit the username/password.
Tools
Tool | What it does |
| Start a manual DAG run, optionally with a |
| State of a run plus per-task states (task, state, try number, operator, timing). |
| Logs for one task attempt, tailed to the last N lines by default. |
| Recent runs of a DAG — find a run when you don't already have its id. |
| Clear tasks so they re-run. Defaults to a dry-run preview. |
| Registered DAGs with their paused / import-error / active flags. |
| Parse failures with filename and traceback — why a new DAG isn't showing up. |
| Pause or unpause a DAG (new local DAGs start paused). |
| Read Airflow Variables (read-only). |
| Read Airflow Connections, minus passwords (read-only). |
The four list_* tools, get_run_status, get_task_logs, and get_import_errors are
strictly read-only. trigger_dag, set_dag_paused, and clear_task_instances change
cluster state. There are deliberately no tools that create or modify Variables or
Connections.
License
MIT — see LICENSE.
Maintenance
Resources
Unclaimed servers have limited discoverability.
Looking for Admin?
If you are the server author, to access and configure the admin panel.
Latest Blog Posts
- Your AI Chatbot Just Exposed Your CEO's Salary to an InternBy Om-Shree-0709 on .Agent IdentityMCP SecurityOAuth Delegation
- Why MCP Servers Need Execution Sandboxing (And Why Your Current Stack Isn't Enough)By Om-Shree-0709 on .Agentic AiPrompt InjectionWebAssembly
MCP directory API
We provide all the information about MCP servers via our MCP API.
curl -X GET 'https://glama.ai/api/mcp/v1/servers/BrianLondon/airflow-dev-mcp'
If you have feedback or need assistance with the MCP directory API, please join our Discord server