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