From ff264f73823f384008d9abd32a56328a959d8c62 Mon Sep 17 00:00:00 2001 From: houxu Date: Wed, 29 Oct 2025 10:30:47 +0800 Subject: [PATCH] update query mcp --- scripts/deploy/4-other-script/agent_manager.py | 14 ++++++-------- 1 file changed, 6 insertions(+), 8 deletions(-) diff --git a/scripts/deploy/4-other-script/agent_manager.py b/scripts/deploy/4-other-script/agent_manager.py index dbd7fc5..2fa17cb 100644 --- a/scripts/deploy/4-other-script/agent_manager.py +++ b/scripts/deploy/4-other-script/agent_manager.py @@ -361,17 +361,16 @@ async def process_mcp_config(api_client: ApiClient, config_path: str) -> str: async def query_mcp_server(api_client: ApiClient, mcp_id: str) -> dict[str, Any] | None: """查询MCP服务状态""" logger.debug("查询MCP服务状态: %s", mcp_id) - response = await api_client.request("GET", "/api/mcp") + response = await api_client.request("GET", "/api/mcp/"+mcp_id) if response.get("code") != HTTP_OK: msg = f"查询MCP服务失败: {response.get('message', '未知错误')}" raise RuntimeError(msg) - services = response.get("result", {}).get("services", []) - for service in services: - if service.get("mcpserviceId") == mcp_id: - logger.debug("MCP服务 %s 状态: %s", mcp_id, service.get("status")) - return service + service = response.get("result", {}) + if service.get("serviceId") == mcp_id: + logger.debug("MCP服务 %s 状态: %s", mcp_id, service.get("status")) + return service return None @@ -484,8 +483,7 @@ async def create_agent(api_client: ApiClient, config_path: str) -> None: mcp_server = await wait_for_mcp_service(api_client, service_id) # 激活服务（如果未激活） - if not mcp_server.get("isActive"): - await activate_mcp_server(api_client, service_id) + await activate_mcp_server(api_client, service_id) # 创建应用数据 app_name = mcp_server.get("name", f"agent_{service_id[:6]}")[:20] -- Gitee