lib/sidekiq/api.rb in sidekiq-5.2.9 vs lib/sidekiq/api.rb in sidekiq-5.2.10

- old
+ new

@@ -162,10 +162,12 @@ end end class History def initialize(days_previous, start_date = nil) + #we only store five years of data in Redis + raise ArgumentError if days_previous < 1 || days_previous > (5 * 365) @days_previous = days_previous @start_date = start_date || Time.now.utc.to_date end def processed @@ -902,10 +904,10 @@ def each Sidekiq.redis do |conn| procs = sscan(conn, 'processes') procs.sort.each do |key| valid, workers = conn.pipelined do - conn.exists(key) + conn.exists?(key) conn.hgetall("#{key}:workers") end next unless valid workers.each_pair do |tid, json| yield key, tid, Sidekiq.load_json(json)