git.iko.soy/crush
on main help sign in
fix: remove timout
2eaad51Kujtim Hoxha
internal/llm/provider/anthropic.go+1−1
compare with main
unifiedsplit
@@ -332,7 +332,7 @@ func (a *anthropicClient) stream(ctx context.Context, messages []message.Message
332 // Prepare messages on each attempt in case max_tokens was adjusted
332 // Prepare messages on each attempt in case max_tokens was adjusted
333 preparedMessages := a.preparedMessages(a.convertMessages(messages), a.convertTools(tools))
333 preparedMessages := a.preparedMessages(a.convertMessages(messages), a.convertTools(tools))
334
334
335− opts := []option.RequestOption{option.WithRequestTimeout(time.Minute)}
335+ var opts []option.RequestOption
336 if a.isThinkingEnabled() {
336 if a.isThinkingEnabled() {
337 opts = append(opts, option.WithHeaderAdd("anthropic-beta", "interleaved-thinking-2025-05-14"))
337 opts = append(opts, option.WithHeaderAdd("anthropic-beta", "interleaved-thinking-2025-05-14"))
338 }
338 }
internal/llm/provider/openai.go−1
@@ -337,7 +337,6 @@ func (o *openaiClient) stream(ctx context.Context, messages []message.Message, t
337 openaiStream := o.client.Chat.Completions.NewStreaming(
337 openaiStream := o.client.Chat.Completions.NewStreaming(
338 ctx,
338 ctx,
339 params,
339 params,
340− option.WithRequestTimeout(time.Minute),
341 )
340 )
342
341
343 acc := openai.ChatCompletionAccumulator{}
342 acc := openai.ChatCompletionAccumulator{}