list_connections
Retrieve all configured connections from Apache Airflow to manage data pipelines and external integrations.
Instructions
[Tool Role]: Lists all connections in Airflow.
Input Schema
TableJSON Schema
| Name | Required | Description | Default |
|---|---|---|---|
| limit | No | ||
| offset | No |
Implementation Reference
- Implementation of the list_connections MCP tool handler. Fetches paginated list of Airflow connections using the generic airflow_request function.@mcp.tool() async def list_connections(limit: int = 20, offset: int = 0) -> Dict[str, Any]: """[Tool Role]: Lists all connections in Airflow.""" params = {'limit': limit, 'offset': offset} query_string = "&".join([f"{k}={v}" for k, v in params.items()]) resp = await airflow_request("GET", f"/connections?{query_string}") resp.raise_for_status() return resp.json()
- src/mcp_airflow_api/tools/v1_tools.py:23-23 (registration)Registration call for all common tools (including list_connections) in the v1 tools module.common_tools.register_common_tools(mcp)
- src/mcp_airflow_api/tools/v2_tools.py:24-24 (registration)Registration call for all common tools (including list_connections) in the v2 tools module.common_tools.register_common_tools(mcp)