diff options
Diffstat (limited to 'app/workers/schedule_merge_request_cleanup_refs_worker.rb')
| -rw-r--r-- | app/workers/schedule_merge_request_cleanup_refs_worker.rb | 13 |
1 files changed, 1 insertions, 12 deletions
diff --git a/app/workers/schedule_merge_request_cleanup_refs_worker.rb b/app/workers/schedule_merge_request_cleanup_refs_worker.rb index b5ea5298879..40a773ca58f 100644 --- a/app/workers/schedule_merge_request_cleanup_refs_worker.rb +++ b/app/workers/schedule_merge_request_cleanup_refs_worker.rb @@ -10,21 +10,10 @@ class ScheduleMergeRequestCleanupRefsWorker tags :exclude_from_kubernetes idempotent! - # Based on existing data, MergeRequestCleanupRefsWorker can run 3 jobs per - # second. This means that 180 jobs can be performed but since there are some - # spikes from time time, it's better to give it some allowance. - LIMIT = 180 - DELAY = 10.seconds - BATCH_SIZE = 30 - def perform return if Gitlab::Database.read_only? return unless Feature.enabled?(:merge_request_refs_cleanup, default_enabled: false) - ids = MergeRequest::CleanupSchedule.scheduled_merge_request_ids(LIMIT).map { |id| [id] } - - MergeRequestCleanupRefsWorker.bulk_perform_in(DELAY, ids, batch_size: BATCH_SIZE) # rubocop:disable Scalability/BulkPerformWithContext - - log_extra_metadata_on_done(:merge_requests_count, ids.size) + MergeRequestCleanupRefsWorker.perform_with_capacity end end |