Function execute_mcp_tool_with_endpoint

api_utils/mcp_adapter.py:41–57

(
    endpoint: str, name: str, params: Dict[str, Any]
)

async def execute_mcp_tool_with_endpoint(
    endpoint: str, name: str, params: Dict[str, Any]
) -> str:
    url = f"{_normalize_endpoint(endpoint)}/tools/execute"
    payload = {"name": name, "arguments": params}
    headers = {"Content-Type": "application/json"}
    timeout = float(os.environ.get("MCP_HTTP_TIMEOUT", "15"))
    async with httpx.AsyncClient(timeout=timeout) as client:
        resp = await client.post(url, json=payload, headers=headers)
        resp.raise_for_status()
        try:
            data = resp.json()
        except asyncio.CancelledError:
            raise
        except Exception:
            data = {"raw": resp.text}
    return json.dumps(data, ensure_ascii=False)