lib/sidekiq/throttled/strategy/concurrency.rb in sidekiq-throttled-0.11.0 vs lib/sidekiq/throttled/strategy/concurrency.rb in sidekiq-throttled-0.12.0

- old
+ new

@@ -44,15 +44,15 @@ def throttled?(jid, *job_args) job_limit = limit(job_args) return false unless job_limit return true if job_limit <= 0 - kwargs = { - :keys => [key(job_args)], - :argv => [jid.to_s, job_limit, @ttl, Time.now.to_f] - } + keys = [key(job_args)] + argv = [jid.to_s, job_limit, @ttl, Time.now.to_f] - Sidekiq.redis { |redis| 1 == SCRIPT.eval(redis, kwargs) } + Sidekiq.redis do |redis| + 1 == SCRIPT.eval(redis, :keys => keys, :argv => argv) + end end # @return [Integer] Current count of jobs def count(*job_args) Sidekiq.redis { |conn| conn.zcard(key(job_args)) }.to_i