lib/sidekiq/throttled/patches/super_fetch.rb in sidekiq-throttled-1.4.0 vs lib/sidekiq/throttled/patches/super_fetch.rb in sidekiq-throttled-1.5.0
- old
+ new
@@ -12,22 +12,9 @@
base.prepend(ThrottledRetriever)
end
private
- # Calls SuperFetch UnitOfWork's requeue to remove the job from the
- # temporary queue and push job back to the head of the queue, so that
- # the job won't be tried immediately after it was requeued (in most cases).
- #
- # @note This is triggered when job is throttled.
- #
- # @return [void]
- def requeue_throttled(work)
- # SuperFetch UnitOfWork's requeue will remove it from the temporary
- # queue and then requeue it, so no acknowledgement call is needed.
- work.requeue
- end
-
# Returns list of non-paused queues to try to fetch jobs from.
#
# @note It may return an empty array.
# @return [Array<Array(String, String)>]
def active_queues