diff --git a/internal/llm/agent/agent.go b/internal/llm/agent/agent.go index 91661dabc7bbe6a8099a67dc24b43de2a9545dbf..1f260f7c4134a3561f34aa64aa2096a9cd14641d 100644 --- a/internal/llm/agent/agent.go +++ b/internal/llm/agent/agent.go @@ -567,7 +567,7 @@ loop: } // Reset the timeout timer since we received a chunk timer.Reset(streamChunkTimeout) - + if processErr := a.processEvent(ctx, sessionID, &assistantMsg, event); processErr != nil { if errors.Is(processErr, context.Canceled) { a.finishMessage(context.Background(), &assistantMsg, message.FinishReasonCanceled, "Request cancelled", "")