MCP-Airflow-API
JSON →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.
Install
uvx --python Tools · 47
- 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)
Environment variables
AIRFLOW_API_BASE_URLFASTMCP_PORTREMOTE_SECRET_KEYAIRFLOW_WEBSERVER_PORTAIRFLOW_APISERVER_PORT
Links
★ 47 GitHub stars