From b24ee0b9a6061c5c1255b91fc769e03d8919a3e2 Mon Sep 17 00:00:00 2001 From: hrz <1710360675@qq.com> Date: Sat, 31 May 2025 10:14:23 +0800 Subject: [PATCH] =?UTF-8?q?update:=E4=BF=AE=E5=A4=8D=E5=8F=82=E6=95=B0?= =?UTF-8?q?=E9=94=99=E8=AF=AF?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- main/xiaozhi-server/core/mcp/MCPClient.py | 12 +++++++++--- 1 file changed, 9 insertions(+), 3 deletions(-) diff --git a/main/xiaozhi-server/core/mcp/MCPClient.py b/main/xiaozhi-server/core/mcp/MCPClient.py index 38a8e62a..b6b6335f 100644 --- a/main/xiaozhi-server/core/mcp/MCPClient.py +++ b/main/xiaozhi-server/core/mcp/MCPClient.py @@ -92,15 +92,21 @@ class MCPClient: args=self.config.get("args", []), env=env, ) - stdio_r, stdio_w = await stack.enter_async_context(stdio_client(params)) + stdio_r, stdio_w = await stack.enter_async_context( + stdio_client(params) + ) read_stream, write_stream = stdio_r, stdio_w # 建立SSEClient elif "url" in self.config: if "API_ACCESS_TOKEN" in self.config: - headers = {"Authorization": f"Bearer {self.config['API_ACCESS_TOKEN']}"} + headers = { + "Authorization": f"Bearer {self.config['API_ACCESS_TOKEN']}" + } else: headers = {} - sse_r, sse_w = await stack.enter_async_context(sse_client(self.config["url"], , headers=headers)) + sse_r, sse_w = await stack.enter_async_context( + sse_client(self.config["url"], headers=headers) + ) read_stream, write_stream = sse_r, sse_w else: