diff options
| author | Claire <claire.github-309c@sitedethib.com> | 2022-02-08 19:43:59 +0100 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2022-02-08 19:43:59 +0100 |
| commit | 2fd1db7c9d0fe8c1cca159b9b0818c72e7c318aa (patch) | |
| tree | bc7319ae242a889bb1d05b7afdd365d78a43ac1d /app/workers/scheduler/accounts_statuses_cleanup_scheduler.rb | |
| parent | b1983623aec8e0b066d115736d2151e0c74407fa (diff) | |
| parent | 692963d43beb5e66a86e15d63b5aa3eeca82f0a1 (diff) | |
Merge pull request #1680 from ClearlyClaire/glitch-soc/merge-upstream
Merge upstream changes
Diffstat (limited to 'app/workers/scheduler/accounts_statuses_cleanup_scheduler.rb')
| -rw-r--r-- | app/workers/scheduler/accounts_statuses_cleanup_scheduler.rb | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/app/workers/scheduler/accounts_statuses_cleanup_scheduler.rb b/app/workers/scheduler/accounts_statuses_cleanup_scheduler.rb index f42d4bca6..7195f0ff9 100644 --- a/app/workers/scheduler/accounts_statuses_cleanup_scheduler.rb +++ b/app/workers/scheduler/accounts_statuses_cleanup_scheduler.rb @@ -66,7 +66,7 @@ class Scheduler::AccountsStatusesCleanupScheduler end def compute_budget - threads = Sidekiq::ProcessSet.new.filter { |x| x['queues'].include?('push') }.map { |x| x['concurrency'] }.sum + threads = Sidekiq::ProcessSet.new.select { |x| x['queues'].include?('push') }.map { |x| x['concurrency'] }.sum [PER_THREAD_BUDGET * threads, MAX_BUDGET].min end |