lib/sidekiq/api.rb in sidekiq-2.14.1 vs lib/sidekiq/api.rb in sidekiq-2.15.0
- old
+ new
@@ -258,10 +258,10 @@
Sidekiq.redis {|c| c.zcard(@zset) }
end
def schedule(timestamp, message)
Sidekiq.redis do |conn|
- conn.zadd(@zset, timestamp.to_s, Sidekiq.dump_json(message))
+ conn.zadd(@zset, timestamp.to_f.to_s, Sidekiq.dump_json(message))
end
end
def each(&block)
# page thru the sorted set backwards so deleting entries doesn't screw up indexing