Apache Airflow MCP Server

A Model Context Protocol (MCP) server implementation for Apache Airflow, enabling seamless integration with MCP clients. This project provides a

Local serverstdioPython

What is the Apache Airflow MCP Server?

A Model Context Protocol (MCP) server implementation for Apache Airflow, enabling seamless integration with MCP clients. This project provides a standardized way to

What it actually does

This project implements a Model Context Protocol server that wraps Apache Airflow's REST API, allowing MCP clients to interact with Airflow in a standardized way. It uses the official Apache Airflow client library to ensure compatibility and maintainability.

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
configconnections
dagdagrun
dagstatsdataset
eventlogimporterror
monitoringplugin
poolprovider
taskinstancevariable

Configuration

VariableDescriptionRequired
AIRFLOW_HOSTEndpoint or connection string the server talks to.Optional
AIRFLOW_USERNAMEConfiguration value read at startup.Optional
AIRFLOW_PASSWORDConfiguration value read at startup.Optional
AIRFLOW_JWT_TOKENCredential the server authenticates with.Yes
READ_ONLYConfiguration value read at startup.Optional
ENDPOINT_URLEndpoint or connection string the server talks to.Yes

Example prompts to try

  • “Use Apache Airflow to config.”
  • “Use Apache Airflow to dag.”
  • “Use Apache Airflow to dagstats.”

Frequently asked questions

A Model Context Protocol (MCP) server implementation for Apache Airflow, enabling seamless integration with MCP clients. This project provides a standardized way to Confirm the tools offered by your installed version in the connected client. Tool availability and permissions depend on the server and account configuration.