diff --git a/internal/rpc/rpc.go b/internal/rpc/rpc.go index 33f8a9bbda..a96a3ec77d 100644 --- a/internal/rpc/rpc.go +++ b/internal/rpc/rpc.go @@ -177,7 +177,7 @@ func RetryStreamingClientStream[Req, Resp any]( // We've hit an error. _, closeErr := stream.CloseAndReceive() if closeErr != nil { - logger.Logf(logLevel, "Failed to close stream: %s", closeErr) + logger.Logf(log.Debug, "Failed to close stream: %s", closeErr) } errored = true