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)