lib/sidekiq/limit_fetch/global/semaphore.rb in sidekiq-limit_fetch-3.4.0 vs lib/sidekiq/limit_fetch/global/semaphore.rb in sidekiq-limit_fetch-4.0.0

- old
+ new

@@ -107,9 +107,17 @@ def blocking? redis {|it| it.get "#{PREFIX}:block:#@name" } end + def clear_limits + redis do |it| + %w(block busy limit pause probed process_limit).each do |key| + it.del "#{PREFIX}:#{key}:#@name" + end + end + end + def increase_local_busy @lock.synchronize { @local_busy += 1 } end def decrease_local_busy