diff options
| -rw-r--r-- | internal/llm/agent/mcp-tools.go | 2 | ||||
| -rw-r--r-- | internal/llm/provider/anthropic.go | 4 |
2 files changed, 3 insertions, 3 deletions
diff --git a/internal/llm/agent/mcp-tools.go b/internal/llm/agent/mcp-tools.go index d54f04a9c..237560641 100644 --- a/internal/llm/agent/mcp-tools.go +++ b/internal/llm/agent/mcp-tools.go @@ -58,7 +58,7 @@ func runTool(ctx context.Context, c MCPClient, toolName string, input string) (t toolRequest := mcp.CallToolRequest{} toolRequest.Params.Name = toolName var args map[string]any - if err = json.Unmarshal([]byte(input), &input); err != nil { + if err = json.Unmarshal([]byte(input), &args); err != nil { return tools.NewTextErrorResponse(fmt.Sprintf("error parsing parameters: %s", err)), nil } toolRequest.Params.Arguments = args diff --git a/internal/llm/provider/anthropic.go b/internal/llm/provider/anthropic.go index e5c478a7f..bb120b6ad 100644 --- a/internal/llm/provider/anthropic.go +++ b/internal/llm/provider/anthropic.go @@ -213,7 +213,7 @@ func (a *anthropicClient) send(ctx context.Context, messages []message.Message, return nil, retryErr } if retry { - logging.WarnPersist("Retrying due to rate limit... attempt %d of %d", logging.PersistTimeArg, time.Millisecond*time.Duration(after+100)) + logging.WarnPersist(fmt.Sprintf("Retrying due to rate limit... attempt %d of %d", attempts, maxRetries), logging.PersistTimeArg, time.Millisecond*time.Duration(after+100)) select { case <-ctx.Done(): return nil, ctx.Err() @@ -351,7 +351,7 @@ func (a *anthropicClient) stream(ctx context.Context, messages []message.Message return } if retry { - logging.WarnPersist("Retrying due to rate limit... attempt %d of %d", logging.PersistTimeArg, time.Millisecond*time.Duration(after+100)) + logging.WarnPersist(fmt.Sprintf("Retrying due to rate limit... attempt %d of %d", attempts, maxRetries), logging.PersistTimeArg, time.Millisecond*time.Duration(after+100)) select { case <-ctx.Done(): // context cancelled |