lib/sidekiq/throttled/strategy_collection.rb in sidekiq-throttled-1.4.0 vs lib/sidekiq/throttled/strategy_collection.rb in sidekiq-throttled-1.5.0
- old
+ new
@@ -39,9 +39,14 @@
# by any strategy in collection.
def throttled?(...)
any? { |s| s.throttled?(...) }
end
+ # @return [Float] How long, in seconds, before we'll next be able to take on jobs
+ def retry_in(*args)
+ max { |s| s.retry_in(*args) }
+ end
+
# Marks job as being processed.
# @return [void]
def finalize!(...)
each { |c| c.finalize!(...) }
end