lib/sidekiq/api.rb in sidekiq-6.0.7 vs lib/sidekiq/api.rb in sidekiq-6.1.0
- old
+ new
@@ -919,10 +919,10 @@
def each
Sidekiq.redis do |conn|
procs = conn.sscan_each("processes").to_a
procs.sort.each do |key|
valid, workers = conn.pipelined {
- conn.exists(key)
+ conn.exists?(key)
conn.hgetall("#{key}:workers")
}
next unless valid
workers.each_pair do |tid, json|
hsh = Sidekiq.load_json(json)