From da416534ebfc5437e22da3d6c6a13cf2ed7c6e3b Mon Sep 17 00:00:00 2001 From: Shlee Date: Mon, 6 May 2024 23:15:09 +0930 Subject: [PATCH] Update suspended_user_cleanup_scheduler.rb --- app/workers/scheduler/suspended_user_cleanup_scheduler.rb | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/app/workers/scheduler/suspended_user_cleanup_scheduler.rb b/app/workers/scheduler/suspended_user_cleanup_scheduler.rb index f198a548c7..20b32d90f8 100644 --- a/app/workers/scheduler/suspended_user_cleanup_scheduler.rb +++ b/app/workers/scheduler/suspended_user_cleanup_scheduler.rb @@ -6,7 +6,7 @@ class Scheduler::SuspendedUserCleanupScheduler # Each processed deletion request may enqueue an enormous # amount of jobs in the `pull` queue, so only enqueue when # the queue is empty or close to being so. - MAX_PULL_SIZE = 50 + MAX_QUEUE_SIZE = 50 # Since account deletion is very expensive, we want to avoid # overloading the server by queuing too much at once. @@ -19,7 +19,7 @@ class Scheduler::SuspendedUserCleanupScheduler sidekiq_options retry: 0, lock: :until_executed, lock_ttl: 1.day.to_i def perform - return if Sidekiq::Queue.new('low_delivery').size > MAX_PULL_SIZE + return if Sidekiq::Queue.new('low_delivery').size > MAX_QUEUE_SIZE process_deletion_requests! end