MCP Airflow Simple MCP Server

A **Model Context Protocol (MCP) server** for Apache Airflow 3 that provides essential tools for DAG management, monitoring, debugging, and

Local serverstdioPython

What is the MCP Airflow Simple MCP Server?

A Model Context Protocol (MCP) server for Apache Airflow 3 that provides essential tools for DAG management, monitoring, debugging, and connection testing

Configuration and credentials

  • Python 3.8+ - Apache Airflow 3.x with REST API enabled - Network access to Airflow instance

More MCP options

Compare MCP servers by category, or browse hosted MCP servers if you prefer an endpoint over a local process.

Maintainer setup documentation.

Recorded tools

Check the linked publisher documentation and your connected client's tool list. Names and availability can vary with the server version and account permissions.

ToolWhat it does
get_dagsList all DAGs in Airflow. json { "only_active": false, "limit": 100 }
get_dag_tasksGet all tasks in a specific DAG. json { "dag_id": "example_dag" }
trigger_dag_runTrigger a new DAG run. json { "dag_id": "example_dag", "conf": {"key": "value"}, "logical_date": "2026-01-05T00:00:00Z" }
clear_dag_runClear/retry a DAG run (resets failed tasks). json { "dag_id": "example_dag", "dag_run_id": "manual__2026-01-05T00:00:00+00:00", "dry_run": false }
set_dag_state
get_dag_runsGet DAG run history with optional state filtering. json { "dag_id": "example_dag", "state": "failed", "limit": 25 }
get_task_instancesGet task instances for a specific DAG run. json { "dag_id": "example_dag", "dag_run_id": "manual__2026-01-05T00:00:00+00:00" }
get_dag_stats
get_task_logsGet execution logs for a specific task instance. json { "dag_id": "example_dag", "dag_run_id": "manual__2026-01-05T00:00:00+00:00", "task_id": "example_task", "try_number": 1 }
get_import_errors
get_connectionsList all Airflow connections. json { "limit": 100 }
get_connectionGet details of a specific connection. json { "connection_id": "postgres_default" }
test_connectionTest connection accessibility. json { "connection_id": "postgres_default" }
check_healthCheck Airflow system health (includes Metadatabase, Scheduler, Triggerer, and DagProcessor). json {}

How to install the MCP Airflow Simple MCP Server

{
  "mcpServers": {
    "airflow": {
      "command": "python",
      "args": [
        "c:\\{path_to_your_folder}\\mcp-airflow-simple\\server.py"
      ],
      "env": {
        "GIT_AUTO_UPDATE": "true"
      }
    }
  }
}

From the project documentation. Replace placeholders and example paths before connecting.

Configuration

  • Python 3.8+ - Apache Airflow 3.x with REST API enabled - Network access to Airflow instance
VariableDescriptionRequired
GIT_AUTO_UPDATEDeclared in the maintainer’s client configuration.Check documentation

Example prompts to try

  • “Use MCP Airflow Simple to get dags.”
  • “Use MCP Airflow Simple to get dag tasks.”
  • “Use MCP Airflow Simple to trigger dag run.”

Frequently asked questions

A **Model Context Protocol (MCP) server** for Apache Airflow 3 that provides essential tools for DAG management, monitoring, debugging, and connection testing Confirm the tools offered by your installed version in the connected client. Tool availability and permissions depend on the server and account configuration.