MCP-Airflow-API
MCP-Airflow-API turns plain-language requests into Apache Airflow 2 and 3 REST API calls: DAGs, runs, tasks and cluster health.
- 54 ★ on the repository
- Last commit
Broad access
Why this level
- It triggers and pauses DAGs and changes Airflow resources with the account's rights.
- It keeps the Airflow URL and password in client environment variables.
Install
- Works in
Manual install
uvx --python 3.12 mcp-airflow-apiThe PyPI option with `uvx` from the README install table. Claude Desktop also has an `.mcpb` extension in releases.
Access and checks
How we reviewBroad accessThe tool can change data, run commands or handle secrets.
- It triggers and pauses DAGs and changes Airflow resources with the account's rights.
- It keeps the Airflow URL and password in client environment variables.
This is third-party code. Review the repository files before installing.
What it does
MCP-Airflow-API is an MCP server that turns requests such as show failed tasks from the last day into Apache Airflow REST API calls. One server handles both Airflow 2.x (API v1) and Airflow 3.x (API v2), chosen by `AIRFLOW_API_VERSION`. The agent inspects DAGs, DAG runs, task instances, pools, variables, connections and cluster health. Triggering, pausing and other operations run with the rights of the configured Airflow account. Transport is stdio or Streamable HTTP, clients include Claude Desktop, OpenWebUI and any MCP client, with an optional MCPO proxy for OpenAPI.
Who it is for. Data engineers and platform teams who watch Airflow and want to ask about pipelines in plain words.
Good fit when
- Tasks failed overnight and a list of failed instances from the last 24 hours is needed.
- The `example_etl` DAG must run with today's processing date.
- Cluster health and pools must be checked without opening the web interface.
- A team on Airflow 3 wants to see assets updated by a given DAG.
Not a fit when
- The Airflow account has admin rights while the agent only needs read checks.
- The Airflow API is unreachable from the agent's network.
- DAG code edits are needed rather than run management.
Example request
Show the DAGs running now and the list of failed tasks from the last 24 hours.MCP
- Transport
- stdio, http
- Authentication
- API key
Environment variables
AIRFLOW_API_BASE_URLrequired- Airflow API root without a version suffix, for example `http://localhost:8080/api`.
AIRFLOW_API_USERNAMErequired- Airflow API user name.
AIRFLOW_API_PASSWORDrequired, secret- Airflow API password.
AIRFLOW_API_VERSION- `v1` for Airflow 2.x (default) or `v2` for Airflow 3.x.
Limitations
An Airflow account and network access to its API are required. The base URL is given without a version suffix, for example `http://localhost:8080/api`. The agent acts with that account's rights, so create a dedicated user with minimal rights because the tool can trigger and pause DAGs. The password sits in environment variables, and the server listens on `127.0.0.1:8000` in HTTP mode by default. API v2 features exist only on Airflow 3.
How to disable. Remove the server entry from client settings and uninstall the extension in Claude Desktop. Stop the Docker Compose containers if you ran MCPO. Delete the dedicated Airflow user in Airflow itself.
FAQ
How do I connect it to Claude Desktop?
Download the `.mcpb` from the latest release, open Settings, Extensions, Install Extension, pick API `v1` or `v2` and enter URL, user and password.
Which Airflow version setting do I use?
For Airflow 2.x set `AIRFLOW_API_VERSION=v1`, the default. For Airflow 3.x set `v2`.
How do I run it without Claude Desktop?
With `uvx --python 3.12 mcp-airflow-api` or through Docker Compose with OpenWebUI. `FASTMCP_TYPE` sets transport: `stdio` or `streamable-http`.
Where can I get a test cluster?
The author points to a separate Airflow-Docker-Compose repository with a ready stand.
What does the server do besides reads?
It triggers and pauses DAGs and changes supported resources within the Airflow account's rights.
Discussion
No questions or reviews yet.
Related
MCP serversOfficial Cloudflare MCP server: the agent drives the whole Cloudflare API by searching the spec and running code
A self-hosted gateway that merges several MCP servers into one endpoint with auth and tool selection
Azure DevOps MCP server
Azure DevOps MCP Server
Official Microsoft MCP server for Azure DevOps: work items, repositories, builds, test plans, and wiki from the agent
The cronstable job scheduler exposes its jobs, run history and schedule debugging to an agent through MCP.
mcpd starts MCP servers from one .mcpd.toml file and serves them to agents and scripts as a plain HTTP API on a local port
A self-hosted gateway routes internal MCP tools, authenticates users and records requests for later review.
README in short
The server covers DAGs, runs, tasks, pools, variables and connections and takes requests from any MCP client. OpenWebUI has Docker Compose and the MCPO proxy.