create_connection
Add a new connection to Apache Airflow clusters for data pipeline integration, enabling task monitoring and DAG inspection through the MCP server.
Instructions
[Tool Role]: Creates a new connection.
Input Schema
TableJSON Schema
| Name | Required | Description | Default |
|---|---|---|---|
| connection_data | Yes |
Implementation Reference
- The core implementation of the 'create_connection' MCP tool handler. It performs a POST request to Airflow's /connections endpoint using the provided connection_data dictionary.async def create_connection(connection_data: Dict[str, Any]) -> Dict[str, Any]: """[Tool Role]: Creates a new connection.""" resp = await airflow_request("POST", "/connections", json=connection_data) resp.raise_for_status() return resp.json()
- src/mcp_airflow_api/tools/v1_tools.py:23-23 (registration)Registration invocation for Airflow v1 tools, which includes the create_connection tool via common_tools.register_common_tools(mcp).common_tools.register_common_tools(mcp)
- src/mcp_airflow_api/tools/v2_tools.py:24-24 (registration)Registration invocation for Airflow v2 tools, which includes the create_connection tool via common_tools.register_common_tools(mcp).common_tools.register_common_tools(mcp)