mirror of
https://github.com/mperham/sidekiq.git
synced 2022-11-09 13:52:34 -05:00
Early exit for noop requeue
This commit is contained in:
parent
eb438ae66e
commit
934f91cd2c
1 changed files with 2 additions and 0 deletions
|
@ -93,6 +93,8 @@ module Sidekiq
|
|||
# By leaving this as a class method, it can be pluggable and used by the Manager actor. Making it
|
||||
# an instance method will make it async to the Fetcher actor
|
||||
def self.bulk_requeue(inprogress, options)
|
||||
return if inprogress.empty?
|
||||
|
||||
Sidekiq.logger.debug { "Re-queueing terminated jobs" }
|
||||
jobs_to_requeue = {}
|
||||
inprogress.each do |unit_of_work|
|
||||
|
|
Loading…
Reference in a new issue