delete_connection
Remove a specific connection from an Apache Airflow cluster to manage data pipeline configurations and maintain cluster organization.
Instructions
[Tool Role]: Deletes a connection.
Input Schema
TableJSON Schema
| Name | Required | Description | Default |
|---|---|---|---|
| connection_id | Yes |
Implementation Reference
- The core handler function for the 'delete_connection' tool. It performs a DELETE request to the Airflow connections endpoint using the shared airflow_request function. The @mcp.tool() decorator registers it directly within the common tools registration function.@mcp.tool() async def delete_connection(connection_id: str) -> Dict[str, Any]: """[Tool Role]: Deletes a connection.""" resp = await airflow_request("DELETE", f"/connections/{connection_id}") resp.raise_for_status() return {"message": f"Connection {connection_id} deleted successfully"}
- src/mcp_airflow_api/tools/v1_tools.py:23-23 (registration)Registration call for v1 API tools. Invokes register_common_tools(mcp) which includes the delete_connection tool registration.common_tools.register_common_tools(mcp)
- src/mcp_airflow_api/tools/v2_tools.py:24-24 (registration)Registration call for v2 API tools. Invokes register_common_tools(mcp) which includes the delete_connection tool registration.common_tools.register_common_tools(mcp)