get_connection
Retrieve connection configuration details from Apache Airflow clusters to manage data pipeline integrations and monitor connectivity settings.
Instructions
[Tool Role]: Gets details for a specific connection.
Input Schema
TableJSON Schema
| Name | Required | Description | Default |
|---|---|---|---|
| connection_id | Yes |
Output Schema
TableJSON Schema
| Name | Required | Description | Default |
|---|---|---|---|
No arguments | |||
Implementation Reference
- The main handler function for the 'get_connection' MCP tool. It makes a GET request to the Airflow API to retrieve details for a specific connection by its ID. The function is automatically registered as an MCP tool via the @mcp.tool() decorator.
@mcp.tool() async def get_connection(connection_id: str) -> Dict[str, Any]: """[Tool Role]: Gets details for a specific connection.""" resp = await airflow_request("GET", f"/connections/{connection_id}") resp.raise_for_status() return resp.json()