MCP-Airflow-API

stdionone★ 47other

MCP-Airflow-API is an MCP server that leverages the Model Context Protocol (MCP) to transform Apache Airflow REST API operations into natural language tools. This project hides the complexity of API structures and enables intuitive management of Airflow clusters through natural language commands.

github ↗

Install

How to run this server

[ { "cmd": "uvx --python", "imports": [] } ]

server path: mcp-airflow-api

Tools

What this server exposes

get_dags

List all DAGs in the Airflow cluster

get_dag_details

Get details of a specific DAG

trigger_dag

Trigger a DAG run

get_dag_runs

List DAG runs for a specific DAG

get_dag_run_details

Get details of a specific DAG run

get_task_instances

List task instances for a DAG run

get_task_instance_details

Get details of a specific task instance

clear_task_instance

Clear a task instance

set_task_instance_state

Set the state of a task instance

get_pools

List all pools

get_pool_details

Get details of a specific pool

create_pool

Create a new pool

update_pool

Update an existing pool

delete_pool

Delete a pool

get_connections

List all connections

get_connection_details

Get details of a specific connection

create_connection

Create a new connection

update_connection

Update an existing connection

delete_connection

Delete a connection

get_variables

List all variables

get_variable_details

Get details of a specific variable

create_variable

Create a new variable

update_variable

Update an existing variable

delete_variable

Delete a variable

get_providers

List all providers

get_provider_details

Get details of a specific provider

get_import_errors

List all import errors

get_import_error_details

Get details of a specific import error

get_event_logs

List event logs

get_event_log_details

Get details of a specific event log entry

get_health

Get health status of the Airflow instance

get_version

Get version information of the Airflow instance

get_config

Get configuration of the Airflow instance

get_config_section

Get a specific configuration section

get_config_value

Get a specific configuration value

get_roles

List all roles

get_role_details

Get details of a specific role

create_role

Create a new role

update_role

Update an existing role

delete_role

Delete a role

get_users

List all users

get_user_details

Get details of a specific user

create_user

Create a new user

update_user

Update an existing user

delete_user

Delete a user

get_assets

List all assets (v2 only)

get_asset_details

Get details of a specific asset (v2 only)

Configuration

Environment & auth

authnone

envAIRFLOW_API_BASE_URL

envFASTMCP_PORT

envREMOTE_SECRET_KEY

envAIRFLOW_WEBSERVER_PORT

envAIRFLOW_APISERVER_PORT

Resources

githubhttps://github.com/call518/MCP-Airflow-API ↗