lib/sidekiq/throttled/fetch.rb in sidekiq-throttled-0.6.2 vs lib/sidekiq/throttled/fetch.rb in sidekiq-throttled-0.6.3
- old
+ new
@@ -28,10 +28,10 @@
def retrieve_work
work = brpop
return unless work
work = UnitOfWork.new(*work)
- return work unless Throttled.throttled? work.job
+ return work unless work.throttled?
work.throttled_requeue
nil
end