Skip to main content
Glama
call518

MCP-Airflow-API

by call518
OverviewSchemaRelated ServersScoreDiscussions
Python
Hybrid

Server Configuration

Describes the environment variables required to run the server.

NameRequiredDescriptionDefault
AIRFLOW_API_URLYesThe base URL of your Airflow REST API endpoint
MCP_SERVER_PORTNoControls the transport mode selection. When NOT set: Uses stdio transport (traditional MCP mode). When set: Uses http transport (Docker mode)
AIRFLOW_LOG_LEVELNoControls logging verbosity. Values: DEBUG, INFO, WARNING, ERRORINFO
AIRFLOW_API_PASSWORDYesPassword for Airflow API authentication
AIRFLOW_API_USERNAMEYesUsername for Airflow API authentication

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

Features and capabilities supported by this server

Protocol revision2025-11-25

CapabilityDetails
tools
{
  "listChanged": true
}
logging
{}
prompts
{
  "listChanged": false
}
resources
{
  "subscribe": false,
  "listChanged": false
}
extensions
{
  "io.modelcontextprotocol/ui": {}
}
experimental
{}

Tools

Functions exposed to the LLM to take actions

NameDescription
get_prompt_templateB

[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_dagsB

[Tool Role]: Lists all recently failed DAG runs in the Airflow cluster.

trigger_dagC

[Tool Role]: Triggers a new DAG run for a specified Airflow DAG.

pause_dagC

[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_codeC

[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_summaryB

[Tool Role]: Provides summary of event logs across all DAGs.

list_import_errorsC

[Tool Role]: Lists import errors in Airflow.

get_import_errorC

[Tool Role]: Retrieves a specific import error.

all_dag_import_summaryA

[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_healthA

[Tool Role]: Checks Airflow cluster health status.

get_versionB

[Tool Role]: Gets Airflow version information.

get_configC

[Tool Role]: Retrieves Airflow configuration.

list_config_sectionsB

[Tool Role]: Lists all configuration sections with summary.

get_config_sectionC

[Tool Role]: Gets all options within a specific configuration section.

search_config_optionsC

[Tool Role]: Searches for configuration options matching a term.

list_poolsC

[Tool Role]: Lists all pools in Airflow.

get_poolC

[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_linksC

[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_variableC

[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_connectionC

[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_userB

[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_rolesC

[Tool Role]: Lists all roles in the Airflow system (v1 API only).

list_pluginsA

[Tool Role]: Lists all installed plugins in the Airflow system.

list_providersA

[Tool Role]: Lists all provider packages installed in the Airflow system.

get_providerB

[Tool Role]: Gets details of a specific provider package.

list_datasetsA

[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_eventsC

[Tool Role]: Gets events for a specific dataset (v1 API only - v2 uses Assets).

Prompts

Interactive templates invoked by user choice

NameDescription
airflow_cluster_monitoringComprehensive Airflow cluster monitoring assistant. Args: dag_name: Specific DAG to focus on (optional) time_range: Time range for analysis (default: "today")
airflow_troubleshootingSpecialized 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_analysisDAG 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

NameDescription

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