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)
 			}