MCP_TOOLS_TEMPLATE = 'async def _load_mcp_tools(
):\n """Load MCP tools from bundled config (http/sse only)."""\n import json\n from pathlib import Path\n\n mcp_path = Path(__file__).parent / "_mcp.json"\n if not mcp_path.exists():\n return []\n\n try:\n raw = json.loads(mcp_path.read_text())\n except Exception as exc: # noqa: BLE001\n logger.warning("Failed to parse _mcp.json: %s",
exc)\n return []\n\n servers = raw.get("mcpServers",
{})\n connections = {}\n for name, cfg in servers.items():\n transport = cfg.get("type",
cfg.get("transport", "stdio"))\n if transport in ("http",
"sse"):\n conn = {"transport": transport,
"url": cfg["url"]}\n if "headers" in cfg:\n conn["headers"] = cfg["headers"]\n connections[name] = conn\n\n if not connections:\n return []\n\n try:\n from langchain_mcp_adapters.client import MultiServerMCPClient\n\n client = MultiServerMCPClient(connections)\n return await client.get_tools()\n except Exception as exc: # noqa: BLE001\n logger.warning(\n "Failed to load MCP tools from %d server(s): %s",
\n len(connections),
\n exc,
\n
)\n return []\n'