Skip to content

Commit 748e329

Browse files
fix(session): close client after session creation
1 parent 4a19989 commit 748e329

File tree

1 file changed

+5
-0
lines changed

1 file changed

+5
-0
lines changed

pkg/service/cluster/service.go

+5
Original file line numberDiff line numberDiff line change
@@ -578,6 +578,11 @@ func (s *Service) GetSession(ctx context.Context, clusterID uuid.UUID) (session
578578
if err != nil {
579579
return session, errors.Wrap(err, "get client")
580580
}
581+
defer func() {
582+
if err := client.Close(); err != nil {
583+
s.logger.Error(ctx, "Couldn't close scylla client", "error", err)
584+
}
585+
}()
581586

582587
ni, err := client.AnyNodeInfo(ctx)
583588
if err != nil {

0 commit comments

Comments
 (0)