diff options
Diffstat (limited to 'app/workers/authorized_project_update/user_refresh_from_replica_worker.rb')
-rw-r--r-- | app/workers/authorized_project_update/user_refresh_from_replica_worker.rb | 15 |
1 files changed, 4 insertions, 11 deletions
diff --git a/app/workers/authorized_project_update/user_refresh_from_replica_worker.rb b/app/workers/authorized_project_update/user_refresh_from_replica_worker.rb index ef5dcc1cb99..48e3d0837c7 100644 --- a/app/workers/authorized_project_update/user_refresh_from_replica_worker.rb +++ b/app/workers/authorized_project_update/user_refresh_from_replica_worker.rb @@ -14,19 +14,12 @@ module AuthorizedProjectUpdate deduplicate :until_executing, including_scheduled: true def perform(user_id) - if Feature.enabled?(:user_refresh_from_replica_worker_uses_replica_db) - use_replica_if_available do - user = User.find_by_id(user_id) - - if user && project_authorizations_needs_refresh?(user) - enqueue_project_authorizations_refresh(user) - end - end - else + use_replica_if_available do user = User.find_by_id(user_id) - return unless user - user.refresh_authorized_projects(source: self.class.name) + if user && project_authorizations_needs_refresh?(user) + enqueue_project_authorizations_refresh(user) + end end end |