diff options
Diffstat (limited to 'lib/gitlab/sidekiq_middleware/defer_jobs.rb')
| -rw-r--r-- | lib/gitlab/sidekiq_middleware/defer_jobs.rb | 2 |
1 files changed, 2 insertions, 0 deletions
diff --git a/lib/gitlab/sidekiq_middleware/defer_jobs.rb b/lib/gitlab/sidekiq_middleware/defer_jobs.rb index 0a12667865c..6a652f39349 100644 --- a/lib/gitlab/sidekiq_middleware/defer_jobs.rb +++ b/lib/gitlab/sidekiq_middleware/defer_jobs.rb @@ -22,6 +22,8 @@ module Gitlab # Referred in job_logger's 'log_job_done' method to compute proper 'job_status' job['deferred'] = true job['deferred_by'] = deferred_by + job['deferred_count'] ||= 0 + job['deferred_count'] += 1 worker.class.perform_in(delay, *job['args']) counter.increment({ worker: worker.class.name }) |