fix(session): close client after session creation

scylladb · Mar 29, 2024 · 2226fb4 · 2226fb4
1 parent 6b38cea
commit 2226fb4
Showing 1 changed file with 5 additions and 0 deletions.
diff --git a/pkg/service/cluster/service.go b/pkg/service/cluster/service.go
@@ -578,6 +578,11 @@ func (s *Service) GetSession(ctx context.Context, clusterID uuid.UUID) (session
 	if err != nil {
 		return session, errors.Wrap(err, "get client")
 	}
+	defer func() {
+		if err := client.Close(); err != nil {
+			s.logger.Error(ctx, "Couldn't close scylla client", "error", err)
+		}
+	}()
 
 	ni, err := client.AnyNodeInfo(ctx)
 	if err != nil {