MCP-Airflow-API
Server Configuration
Describes the environment variables required to run the server.
| Name | Required | Description | Default |
|---|---|---|---|
| AIRFLOW_API_URL | Yes | The base URL of your Airflow REST API endpoint | |
| MCP_SERVER_PORT | No | Controls the transport mode selection. When NOT set: Uses stdio transport (traditional MCP mode). When set: Uses http transport (Docker mode) | |
| AIRFLOW_LOG_LEVEL | No | Controls logging verbosity. Values: DEBUG, INFO, WARNING, ERROR | INFO |
| AIRFLOW_API_PASSWORD | Yes | Password for Airflow API authentication | |
| AIRFLOW_API_USERNAME | Yes | Username for Airflow API authentication |
Capabilities
Server capabilities have not been inspected yet.
Tools
Functions exposed to the LLM to take actions
| Name | Description |
|---|---|
| get_prompt_templateC | [Tool Role]: Provides comprehensive prompt template for LLM interactions with Airflow operations. Args: section: Optional section name to get specific part of template mode: Optional mode (summary/detailed) to control response verbosity Returns: Comprehensive template or specific section for optimal LLM guidance |
| list_dagsA | [Tool Role]: Lists all DAGs registered in the Airflow cluster with pagination support. Args: limit: Maximum number of DAGs to return (default: 20) offset: Number of DAGs to skip for pagination (default: 0) fetch_all: If True, fetches all DAGs regardless of limit/offset id_contains: Filter DAGs by ID containing this string name_contains: Filter DAGs by display name containing this string Returns: Dict containing dags list, pagination info, and total counts |
| get_dagC | [Tool Role]: Retrieves detailed information for a specific DAG. Args: dag_id: The DAG ID to get details for Returns: Comprehensive DAG details |
| get_dags_detailed_batchC | [Tool Role]: Retrieves detailed information for multiple DAGs in batch with latest run information. |
| running_dagsA | [Tool Role]: Lists all currently running DAG runs in the Airflow cluster. |
| failed_dagsA | [Tool Role]: Lists all recently failed DAG runs in the Airflow cluster. |
| trigger_dagB | [Tool Role]: Triggers a new DAG run for a specified Airflow DAG. |
| pause_dagB | [Tool Role]: Pauses the specified Airflow DAG (prevents scheduling new runs). |
| unpause_dagB | [Tool Role]: Unpauses the specified Airflow DAG (allows scheduling new runs). |
| dag_graphC | [Tool Role]: Retrieves task graph structure for the specified DAG. |
| list_tasksB | [Tool Role]: Lists all tasks within the specified DAG. |
| dag_codeB | [Tool Role]: Retrieves the source code for the specified DAG. |
| list_event_logsC | [Tool Role]: Lists event logs from Airflow. |
| get_event_logC | [Tool Role]: Retrieves a specific event log entry. |
| all_dag_event_summaryC | [Tool Role]: Provides summary of event logs across all DAGs. |
| list_import_errorsB | [Tool Role]: Lists import errors in Airflow. |
| get_import_errorB | [Tool Role]: Retrieves a specific import error. |
| all_dag_import_summaryB | [Tool Role]: Provides summary of import errors across all DAGs. |
| dag_run_durationC | [Tool Role]: Analyzes DAG run durations and performance metrics. |
| dag_task_durationC | [Tool Role]: Analyzes task durations within a DAG run. |
| dag_calendarC | [Tool Role]: Shows DAG schedule and execution calendar for a date range. |
| get_healthB | [Tool Role]: Checks Airflow cluster health status. |
| get_versionB | [Tool Role]: Gets Airflow version information. |
| get_configB | [Tool Role]: Retrieves Airflow configuration. |
| list_config_sectionsB | [Tool Role]: Lists all configuration sections with summary. |
| get_config_sectionB | [Tool Role]: Gets all options within a specific configuration section. |
| search_config_optionsC | [Tool Role]: Searches for configuration options matching a term. |
| list_poolsB | [Tool Role]: Lists all pools in Airflow. |
| get_poolB | [Tool Role]: Gets details for a specific pool. |
| list_task_instances_allC | [Tool Role]: Lists task instances with comprehensive filtering options. |
| get_task_instance_detailsC | [Tool Role]: Gets detailed information for a specific task instance. |
| list_task_instances_batchC | [Tool Role]: Lists task instances in batch with date and state filtering. |
| get_task_instance_extra_linksD | [Tool Role]: Gets extra links for a task instance. |
| get_task_instance_logsC | [Tool Role]: Retrieves logs for a specific task instance. |
| list_variablesC | [Tool Role]: Lists all variables in Airflow. |
| get_variableB | [Tool Role]: Gets the value of a specific variable. |
| list_xcom_entriesC | [Tool Role]: Lists XCom entries for a specific task instance. |
| get_xcom_entryC | [Tool Role]: Gets a specific XCom entry. |
| list_connectionsC | [Tool Role]: Lists all connections in Airflow. |
| get_connectionC | [Tool Role]: Gets details for a specific connection. |
| create_connectionC | [Tool Role]: Creates a new connection. |
| update_connectionD | [Tool Role]: Updates an existing connection. |
| delete_connectionC | [Tool Role]: Deletes a connection. |
| list_usersC | [Tool Role]: Lists all users in the Airflow system (v1 API only). |
| get_userC | [Tool Role]: Gets details of a specific user (v1 API only). |
| list_permissionsB | [Tool Role]: Lists all permissions available in the Airflow system (v1 API only). |
| list_rolesB | [Tool Role]: Lists all roles in the Airflow system (v1 API only). |
| list_pluginsB | [Tool Role]: Lists all installed plugins in the Airflow system. |
| list_providersB | [Tool Role]: Lists all provider packages installed in the Airflow system. |
| get_providerC | [Tool Role]: Gets details of a specific provider package. |
| list_datasetsB | [Tool Role]: Lists all datasets in the Airflow system (v1 API only - v2 uses Assets). |
| get_datasetB | [Tool Role]: Gets details of a specific dataset (v1 API only - v2 uses Assets). |
| list_dataset_eventsB | [Tool Role]: Lists dataset events for data lineage tracking (v1 API only - v2 uses Assets). |
| get_dataset_eventsB | [Tool Role]: Gets events for a specific dataset (v1 API only - v2 uses Assets). |
Prompts
Interactive templates invoked by user choice
| Name | Description |
|---|---|
| airflow_cluster_monitoring | Comprehensive Airflow cluster monitoring assistant. Args: dag_name: Specific DAG to focus on (optional) time_range: Time range for analysis (default: "today") |
| airflow_troubleshooting | Specialized Airflow troubleshooting assistant. Args: issue_type: Type of issue (failed_tasks, slow_dags, resource_issues, general) severity: Issue severity (low, medium, high, critical) |
| airflow_dag_analysis | DAG analysis and optimization assistant. Args: analysis_type: Type of analysis (overview, performance, dependencies, configuration) dag_pattern: Pattern to filter DAGs (optional) |
Resources
Contextual data attached and managed by the client
| Name | Description |
|---|---|
No resources | |
Latest Blog Posts
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/call518/MCP-Airflow-API'
If you have feedback or need assistance with the MCP directory API, please join our Discord server