diff --git a/app/workers/scheduler/suspended_user_cleanup_scheduler.rb b/app/workers/scheduler/suspended_user_cleanup_scheduler.rb index 4ea81c785b3..f198a548c7c 100644 --- a/app/workers/scheduler/suspended_user_cleanup_scheduler.rb +++ b/app/workers/scheduler/suspended_user_cleanup_scheduler.rb @@ -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('pull').size > MAX_PULL_SIZE + return if Sidekiq::Queue.new('low_delivery').size > MAX_PULL_SIZE process_deletion_requests! end