MCP Server Airflow Token
Server Configuration
Describes the environment variables required to run the server.
| Name | Required | Description | Default |
|---|---|---|---|
| AIRFLOW_HOST | No | Your Airflow host URL | http://localhost:8080 |
| AIRFLOW_TOKEN | No | Your Airflow API token for token-based authentication | |
| AIRFLOW_PASSWORD | No | Your Airflow password for basic authentication | |
| AIRFLOW_USERNAME | No | Your Airflow username for basic authentication | |
| AIRFLOW_API_VERSION | No | Airflow API version | v1 |
Instructions
Guidance the server publishes about itself, which clients place ahead of the tool catalog so the model reads it before choosing anything.
This server publishes no instructions, or was last inspected before Glama recorded them.
Capabilities
Server capabilities have not been inspected yet.
Tools
Functions exposed to the LLM to take actions
| Name | Description |
|---|---|
| get_configD | Get current configuration |
| get_valueC | Get a specific option from configuration |
| list_connectionsC | List all connections |
| create_connectionD | Create a connection |
| get_connectionC | Get a connection by ID |
| update_connectionC | Update a connection by ID |
| delete_connectionC | Delete a connection by ID |
| test_connectionD | Test a connection |
| fetch_dagsC | Fetch all DAGs |
| get_dagC | Get a DAG by ID |
| get_dag_detailsC | Get a simplified representation of DAG |
| get_dag_sourceD | Get a source code |
| pause_dagC | Pause a DAG by ID |
| unpause_dagC | Unpause a DAG by ID |
| get_dag_tasksD | Get tasks for DAG |
| get_taskC | Get a task by ID |
| get_tasksC | Get tasks for DAG |
| patch_dagD | Update a DAG |
| patch_dagsC | Update multiple DAGs |
| delete_dagC | Delete a DAG |
| clear_task_instancesC | Clear a set of task instances |
| set_task_instances_stateD | Set a state of task instances |
| reparse_dag_fileC | Request re-parsing of a DAG file |
| post_dag_runC | Trigger a DAG by ID |
| get_dag_runsD | Get DAG runs by ID |
| get_dag_runs_batchC | List DAG runs (batch) |
| get_dag_runC | Get a DAG run by DAG ID and DAG run ID |
| update_dag_run_stateC | Update a DAG run state by DAG ID and DAG run ID |
| delete_dag_runB | Delete a DAG run by DAG ID and DAG run ID |
| clear_dag_runD | Clear a DAG run |
| set_dag_run_noteC | Update the DagRun note |
| get_upstream_dataset_eventsC | Get dataset events for a DAG run |
| get_dag_statsD | Get DAG stats |
| get_datasetsD | List datasets |
| get_datasetC | Get a dataset by URI |
| get_dataset_eventsD | Get dataset events |
| create_dataset_eventD | Create dataset event |
| get_dag_dataset_queued_eventC | Get a queued Dataset event for a DAG |
| get_dag_dataset_queued_eventsC | Get queued Dataset events for a DAG |
| delete_dag_dataset_queued_eventC | Delete a queued Dataset event for a DAG |
| delete_dag_dataset_queued_eventsC | Delete queued Dataset events for a DAG |
| get_dataset_queued_eventsC | Get queued Dataset events for a Dataset |
| delete_dataset_queued_eventsC | Delete queued Dataset events for a Dataset |
| get_event_logsC | List log entries from event log |
| get_event_logC | Get a specific log entry by ID |
| get_import_errorsC | List import errors |
| get_import_errorC | Get a specific import error by ID |
| get_healthC | Get instance status |
| get_versionC | Get version information |
| get_pluginsC | Get a list of loaded plugins |
| get_poolsD | List pools |
| get_poolC | Get a pool by name |
| delete_poolD | Delete a pool |
| post_poolD | Create a pool |
| patch_poolC | Update a pool |
| get_providersC | Get a list of loaded providers |
| get_task_instanceC | Get a task instance by DAG ID, task ID, and DAG run ID |
| list_task_instancesC | List task instances by DAG ID and DAG run ID |
| update_task_instanceC | Update a task instance by DAG ID, DAG run ID, and task ID |
| list_variablesD | List all variables |
| create_variableD | Create a variable |
| get_variableC | Get a variable by key |
| update_variableC | Update a variable by key |
| delete_variableC | Delete a variable by key |
| get_xcom_entriesD | Get all XCom entries |
| get_xcom_entryD | Get an XCom entry |
Prompts
Interactive templates invoked by user choice
| Name | Description |
|---|---|
No prompts | |
Resources
Contextual data attached and managed by the client
| Name | Description |
|---|---|
No resources | |
TDQS
Scored across 66 tools
Most tools have distinct purposes targeting specific resources and actions, such as clear_dag_run vs. delete_dag_run. However, some overlap exists, like get_dag_details and get_dag, which could cause confusion about which to use for DAG information, and get_tasks and get_dag_tasks appear redundant.
Tool names follow a highly consistent verb_noun pattern throughout, using snake_case uniformly. Examples include create_connection, delete_dag, get_config, and update_variable, making them predictable and easy to parse.
With 66 tools, the count is excessive for typical MCP server use, likely overwhelming for agents and indicating poor scoping. While Airflow is complex, this many tools suggests fragmentation rather than a streamlined interface.
The tool set provides comprehensive CRUD and lifecycle coverage for Airflow's domain, including DAGs, tasks, connections, variables, datasets, and more. No obvious gaps are present; it supports full management workflows from creation to deletion and monitoring.