From 85efff4e7a1471e8dd6b798ecb8fb14e7fe9af53 Mon Sep 17 00:00:00 2001 From: tt-P607 <68868379+tt-P607@users.noreply.github.com> Date: Mon, 1 Dec 2025 15:28:34 +0800 Subject: [PATCH] =?UTF-8?q?chore(logging):=20=E8=B0=83=E6=95=B4=E6=B5=81?= =?UTF-8?q?=E5=A4=84=E7=90=86=E7=9A=84=E6=97=A5=E5=BF=97=E7=BA=A7=E5=88=AB?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit 在流循环管理器中降低非关键事件的日志级别，以减少生产环境日志的噪音。 - 将任务处理失败消息从 `warning` 改为 `debug`，因为在某些情况下这是可恢复和预期的状态。 - 将并发保护消息从 `warning` 改为 `debug`，因为这是流控中的正常且预期的部分，而不是错误。 --- src/chat/message_manager/distribution_manager.py | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/src/chat/message_manager/distribution_manager.py b/src/chat/message_manager/distribution_manager.py index 351e61a64..5af3bb7d4 100644 --- a/src/chat/message_manager/distribution_manager.py +++ b/src/chat/message_manager/distribution_manager.py @@ -367,7 +367,7 @@ class StreamLoopManager: await asyncio.sleep(0.1) else: self.stats["total_failures"] += 1 - logger.warning(f"❌ [流工作器] stream={stream_id[:8]}, 任务ID={task_id}, 处理失败") + logger.debug(f"❌ [流工作器] stream={stream_id[:8]}, 任务ID={task_id}, 处理失败") # 5. 计算下次检查间隔 logger.debug(f"🔍 [流工作器] stream={stream_id[:8]}, 循环#{loop_count}, 计算间隔...") @@ -476,8 +476,8 @@ class StreamLoopManager: # 🔒 防止并发处理：如果已经在处理中，直接返回 if context.is_chatter_processing: - logger.warning(f"🔒 [并发保护] stream={stream_id[:8]}, Chatter 正在处理中，跳过本次处理请求") - return False + logger.debug(f"🔒 [并发保护] stream={stream_id[:8]}, Chatter 正在处理中，跳过本次处理请求") + return True # 返回 True，这是正常的保护机制，不是失败 # 设置处理状态为正在处理 self._set_stream_processing_status(stream_id, True)