From e04fb99e4df66d16ada56e2e75189e89a47137b3 Mon Sep 17 00:00:00 2001 From: Rafi Shamim Date: Wed, 10 Aug 2022 18:21:41 -0400 Subject: [PATCH] jobs: make expiration use intended txn priority In aed014f these operations were supposed to be changed to use MinUserPriority. However, they weren't using the appropriate txn, so it didn't have the intended effect. Release note: None --- pkg/jobs/registry.go | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/pkg/jobs/registry.go b/pkg/jobs/registry.go index c06791a62b3c..2bc90981a0a3 100644 --- a/pkg/jobs/registry.go +++ b/pkg/jobs/registry.go @@ -729,7 +729,7 @@ func (r *Registry) Start(ctx context.Context, stopper *stop.Stopper) error { return errors.WithAssertionFailure(err) } _, err := r.ex.ExecEx( - ctx, "expire-sessions", nil, + ctx, "expire-sessions", txn, sessiondata.InternalExecutorOverride{User: username.RootUserName()}, removeClaimsForDeadSessionsQuery, s.ID().UnsafeBytes(), @@ -776,7 +776,7 @@ func (r *Registry) Start(ctx context.Context, stopper *stop.Stopper) error { return errors.WithAssertionFailure(err) } _, err := r.ex.ExecEx( - ctx, "remove-claims-for-session", nil, + ctx, "remove-claims-for-session", txn, sessiondata.InternalExecutorOverride{User: username.RootUserName()}, removeClaimsForSessionQuery, s.ID().UnsafeBytes(), )