From cc114337def2a744ddcfd345414c2399d8234a0d Mon Sep 17 00:00:00 2001 From: jxxghp Date: Thu, 1 Oct 2026 14:52:26 +0800 Subject: [PATCH] fix(agent): forward tool messages to OpenAI stream --- app/api/endpoints/openai.py | 7 +++++++ 1 file changed, 7 insertions(+) diff --git a/app/api/endpoints/openai.py b/app/api/endpoints/openai.py index 756ea50b1..c1e478dcf 100644 --- a/app/api/endpoints/openai.py +++ b/app/api/endpoints/openai.py @@ -133,6 +133,13 @@ class _OpenAIStreamingHandlerMixin: if emitted and self._event_queue is not None: self._event_queue.put_nowait(emitted) + def emit_tool_message(self, message: str) -> str: + """将工具提示转发到 OpenAI SSE 队列，同时保留流式缓冲内容。""" + emitted = str(super().emit_tool_message(message)) # type: ignore[misc] + if emitted and self._event_queue is not None: + self._event_queue.put_nowait(emitted) + return emitted + def flush_pending_tool_summary(self) -> str: emitted = super().flush_pending_tool_summary() if emitted and self._event_queue is not None: