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
MCP server

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.
All reasons and checks

call518/mcp-airflow-api

Install

Manual install

uvx --python 3.12 mcp-airflow-api

The PyPI option with `uvx` from the README install table. Claude Desktop also has an `.mcpb` extension in releases.

Access and checks

How we review

Broad 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_URL required
Airflow API root without a version suffix, for example `http://localhost:8080/api`.
AIRFLOW_API_USERNAME required
Airflow API user name.
AIRFLOW_API_PASSWORD required, 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.

Official

Official Cloudflare MCP server: the agent drives the whole Cloudflare API by searching the spec and running code

MCP serverBroad access1.1KRepository stars

A self-hosted gateway that merges several MCP servers into one endpoint with auth and tool selection

MCP serverBroad access2.8KRepository stars

Azure DevOps MCP server

Azure DevOps MCP Server

Official

Official Microsoft MCP server for Azure DevOps: work items, repositories, builds, test plans, and wiki from the agent

MCP serverBroad access2.1KRepository stars
Official

The cronstable job scheduler exposes its jobs, run history and schedule debugging to an agent through MCP.

MCP serverExtended access138Repository stars
Official

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

CLIExtended access194Repository stars
Official

A self-hosted gateway routes internal MCP tools, authenticates users and records requests for later review.

MCP serverBroad access587Repository stars

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.

README badge

Report a problem