@@ -9,6 +9,7 @@ import (
14 "github.com/anthropics/anthropic-sdk-go"
15 "github.com/anthropics/anthropic-sdk-go"
@@ -270,6 +271,7 @@ func (a *anthropicClient) stream(ctx context.Context, messages []message.Message
270 anthropicStream := a.client.Messages.NewStreaming(
271 anthropicStream := a.client.Messages.NewStreaming(
272 preparedMessages,
273 preparedMessages,
274+ option.WithHeaderAdd("anthropic-beta", "interleaved-thinking-2025-05-14"),
274 accumulatedMessage := anthropic.Message{}
276 accumulatedMessage := anthropic.Message{}
@@ -426,7 +428,8 @@ func (a *anthropicClient) shouldRetry(attempts int, err error) (bool, int64, err
431+ isOverloaded := strings.Contains(apiErr.Error(), "overloaded") || strings.Contains(apiErr.Error(), "rate limit exceeded")
429− if apiErr.StatusCode != 429 && apiErr.StatusCode != 529 {
432+ if apiErr.StatusCode != 429 && apiErr.StatusCode != 529 && !isOverloaded {
430 return false, 0, err
433 return false, 0, err