From e4c7eaffeecde1c4e2fa86f6a24d7b5b799bd717 Mon Sep 17 00:00:00 2001 From: Timothy Messier Date: Wed, 3 Apr 2024 21:10:21 +0000 Subject: [PATCH] backport of commit dea6ca495845d2fba0a1d965e3e396513fab31c6 --- internal/session/repository_connection.go | 4 ++-- internal/session/repository_session.go | 4 ++-- 2 files changed, 4 insertions(+), 4 deletions(-) diff --git a/internal/session/repository_connection.go b/internal/session/repository_connection.go index 11a61e7904..34975d995b 100644 --- a/internal/session/repository_connection.go +++ b/internal/session/repository_connection.go @@ -416,8 +416,8 @@ func (r *ConnectionRepository) closeOrphanedConnections(ctx context.Context, wor ctx, db.StdRetryCnt, db.ExpBackoff{}, - func(reader db.Reader, w db.Writer) error { - rows, err := r.reader.Query(ctx, fmt.Sprintf(orphanedConnectionsCte, notInClause), args) + func(_ db.Reader, w db.Writer) error { + rows, err := w.Query(ctx, fmt.Sprintf(orphanedConnectionsCte, notInClause), args) if err != nil { return errors.Wrap(ctx, err, op) } diff --git a/internal/session/repository_session.go b/internal/session/repository_session.go index 042e96bccb..ccc708b3d8 100644 --- a/internal/session/repository_session.go +++ b/internal/session/repository_session.go @@ -830,9 +830,9 @@ func (r *Repository) CheckIfNotActive(ctx context.Context, reportedSessions []st ctx, db.StdRetryCnt, db.ExpBackoff{}, - func(reader db.Reader, w db.Writer) error { + func(reader db.Reader, _ db.Writer) error { var states []*State - err := r.reader.SearchWhere(ctx, &states, "end_time is null and session_id in (?)", []any{reportedSessions}) + err := reader.SearchWhere(ctx, &states, "end_time is null and session_id in (?)", []any{reportedSessions}) if err != nil { return errors.Wrap(ctx, err, op) }