From 95bf62db88954c3980f339eb1ee58d61eea9afda Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E5=85=AC=E6=98=8E?= <83812544+Ed1s0nZ@users.noreply.github.com> Date: Mon, 15 Jun 2026 21:56:42 +0800 Subject: [PATCH] Add files via upload --- internal/multiagent/eino_adk_run_loop.go | 10 ++++++++++ 1 file changed, 10 insertions(+) diff --git a/internal/multiagent/eino_adk_run_loop.go b/internal/multiagent/eino_adk_run_loop.go index 71ab381f..8d8cc56f 100644 --- a/internal/multiagent/eino_adk_run_loop.go +++ b/internal/multiagent/eino_adk_run_loop.go @@ -785,6 +785,16 @@ func runEinoADKAgentLoop(ctx context.Context, args *einoADKRunLoopArgs, baseMsgs } } } + if progress != nil && reasoningStreamID != "" && strings.TrimSpace(reasoningBuf) != "" { + progress("reasoning_chain_stream_end", openai.DisplayReasoningContent(strings.TrimSpace(reasoningBuf)), map[string]interface{}{ + "streamId": reasoningStreamID, + "conversationId": conversationID, + "source": "eino", + "einoAgent": ev.AgentName, + "einoRole": einoRoleTag(ev.AgentName), + "orchestration": orchMode, + }) + } if streamsMainAssistant(ev.AgentName) { s := strings.TrimSpace(mainAssistantBuf) if mainAssistDupTarget != "" {