From 853357a11bcdce57af9ff847c170c4560c0944fc Mon Sep 17 00:00:00 2001 From: Marcus Ramberg Date: Wed, 1 Oct 2025 18:44:52 +0200 Subject: [PATCH] Improve error message when agent fails to connect --- cmd/agent/core/agent.go | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/cmd/agent/core/agent.go b/cmd/agent/core/agent.go index af15cac154a..1fafc13a16c 100644 --- a/cmd/agent/core/agent.go +++ b/cmd/agent/core/agent.go @@ -140,7 +140,7 @@ func run(ctx context.Context, c *cli.Command, backends []types.Backend) error { authClient := agent_rpc.NewAuthGrpcClient(authConn, agentToken, agentConfig.AgentID) authInterceptor, err := agent_rpc.NewAuthInterceptor(grpcClientCtx, authClient, authInterceptorRefreshInterval) //nolint:contextcheck if err != nil { - return fmt.Errorf("could not create new auth interceptor: %w", err) + return fmt.Errorf("agent could not auth: %w", err) } conn, err := grpc.NewClient( @@ -331,9 +331,9 @@ func runWithRetry(backendEngines []types.Backend) func(ctx context.Context, c *c retryCount := c.Int("connect-retry-count") retryDelay := c.Duration("connect-retry-delay") var err error - for i := 0; i < retryCount; i++ { + for range retryCount { if err = run(ctx, c, backendEngines); status.Code(err) == codes.Unavailable { - log.Warn().Err(err).Msg(fmt.Sprintf("cannot connect to server, retrying in %v", retryDelay)) + log.Warn().Err(err).Msg(fmt.Sprintf("cannot connect to %s, retrying in %v", c.String("server"), retryDelay)) time.Sleep(retryDelay) } else { break