list_connections
Retrieve and display all configured connections from Apache Airflow, enabling users to view connection details, manage access, and monitor integration points within their data workflows.
Instructions
List all connections
Input Schema
TableJSON Schema
| Name | Required | Description | Default |
|---|---|---|---|
| limit | No | ||
| offset | No | ||
| order_by | No |
Implementation Reference
- src/airflow/connection.py:23-39 (handler)The handler function implementing the list_connections tool. It constructs query parameters from inputs and fetches connections from Airflow's ConnectionApi, returning the result as text content.
async def list_connections( limit: Optional[int] = None, offset: Optional[int] = None, order_by: Optional[str] = None, ) -> List[Union[types.TextContent, types.ImageContent, types.EmbeddedResource]]: # Build parameters dictionary kwargs: Dict[str, Any] = {} if limit is not None: kwargs["limit"] = limit if offset is not None: kwargs["offset"] = offset if order_by is not None: kwargs["order_by"] = order_by response = connection_api.get_connections(**kwargs) return [types.TextContent(type="text", text=str(response.to_dict()))] - src/airflow/connection.py:11-20 (registration)Registration of the list_connections tool via get_all_functions(), which provides the function reference, name, description, and read-only status for MCP tool registration.
def get_all_functions() -> list[tuple[Callable, str, str, bool]]: """Return list of (function, name, description, is_read_only) tuples for registration.""" return [ (list_connections, "list_connections", "List all connections", True), (create_connection, "create_connection", "Create a connection", False), (get_connection, "get_connection", "Get a connection by ID", True), (update_connection, "update_connection", "Update a connection by ID", False), (delete_connection, "delete_connection", "Delete a connection by ID", False), (test_connection, "test_connection", "Test a connection", True), ] - src/main.py:24-40 (registration)Mapping in APITYPE_TO_FUNCTIONS dictionary that associates APIType.CONNECTION with get_connection_functions from connection.py, enabling registration of connection tools including list_connections.
APITYPE_TO_FUNCTIONS = { APIType.CONFIG: get_config_functions, APIType.CONNECTION: get_connection_functions, APIType.DAG: get_dag_functions, APIType.DAGRUN: get_dagrun_functions, APIType.DAGSTATS: get_dagstats_functions, APIType.DATASET: get_dataset_functions, APIType.EVENTLOG: get_eventlog_functions, APIType.IMPORTERROR: get_importerror_functions, APIType.MONITORING: get_monitoring_functions, APIType.PLUGIN: get_plugin_functions, APIType.POOL: get_pool_functions, APIType.PROVIDER: get_provider_functions, APIType.TASKINSTANCE: get_taskinstance_functions, APIType.VARIABLE: get_variable_functions, APIType.XCOM: get_xcom_functions, } - src/main.py:95-96 (registration)The loop in main() function that iterates over functions from get_all_functions() and registers each as an MCP tool using app.add_tool.
for func, name, description, *_ in functions: app.add_tool(Tool.from_function(func, name=name, description=description))