diff --git a/internal/llm/provider/anthropic.go b/internal/llm/provider/anthropic.go index bb120b6addc2d1d3d651b67bd320cfa7a1fd4ac9..fc131d348acc6d3664369457b26439bdaac9b47d 100644 --- a/internal/llm/provider/anthropic.go +++ b/internal/llm/provider/anthropic.go @@ -262,7 +262,7 @@ func (a *anthropicClient) stream(ctx context.Context, messages []message.Message event := anthropicStream.Current() err := accumulatedMessage.Accumulate(event) if err != nil { - eventChan <- ProviderEvent{Type: EventError, Error: err} + logging.Warn("Error accumulating message", "error", err) continue }