diff --git a/scripts/deploy/4-other-script/agent_manager.py b/scripts/deploy/4-other-script/agent_manager.py index dbd7fc5b0b791e60f24be190b822df8fc7e87eac..2fa17cbb6fdfa6da63ebe8d91e0dceff1e4f8d45 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]