MCP Server for Apache Airflow
Server Configuration
Describes the environment variables required to run the server.
| Name | Required | Description | Default |
|---|---|---|---|
| AIRFLOW_HOST | Yes | Your Apache Airflow host URL | |
| AIRFLOW_PASSWORD | Yes | Your Apache Airflow password | |
| AIRFLOW_USERNAME | Yes | Your Apache Airflow username |
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_tasksD | Get tasks for DAG |
| patch_dagD | Update a DAG |
| patch_dagsC | Update multiple DAGs |
| delete_dagD | Delete a DAG |
| clear_task_instancesD | 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_batchD | 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_runC | 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_datasetsC | 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_poolC | Create a pool |
| patch_poolD | 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 |
| get_logC | Get the log from a task instance by DAG ID, task ID, DAG run ID and task try number |
| list_task_instance_triesC | List task instance tries by DAG ID, DAG run ID, and task ID |
| list_variablesD | List all variables |
| create_variableD | Create a variable |
| get_variableD | Get a variable by key |
| update_variableC | Update a variable by key |
| delete_variableC | Delete a variable by key |
| get_xcom_entriesC | 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 | |
Latest Blog Posts
- Who's Calling? MCP Hosts Are an Identity Blind Spot (And the Spec Knows It)By Om-Shree-0709 on .mcpAgent IdentityOAuth 2.1
- Your AI Chatbot Just Exposed Your CEO's Salary to an InternBy Om-Shree-0709 on .Agent IdentityMCP SecurityOAuth Delegation
- Why MCP Servers Need Execution Sandboxing (And Why Your Current Stack Isn't Enough)By Om-Shree-0709 on .Agentic AiPrompt InjectionWebAssembly
MCP directory API
We provide all the information about MCP servers via our MCP API.
curl -X GET 'https://glama.ai/api/mcp/v1/servers/yangkyeongmo/mcp-server-apache-airflow'
If you have feedback or need assistance with the MCP directory API, please join our Discord server