kotovalexarian-likes-github/mperham--sidekiq
1
0
Fork 0
mirror of https://github.com/mperham/sidekiq.git synced 2022-11-09 13:52:34 -05:00
Code Releases Activity

Fix SortedEntry#reschedule when called with non float as time (#4342)

Browse source
This commit is contained in:
fatkodima 2019-10-17 16:09:00 +03:00 • committed by Mike Perham
parent 9275dca070
commit 6a4fe1ab8d
2 changed files with 3 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
lib/sidekiq/api.rb
View file

@ -467,7 +467,7 @@ module Sidekiq
def reschedule(at)
Sidekiq.redis do |conn|
conn.zincrby(@parent.name, at - @score, Sidekiq.dump_json(@item))
conn.zincrby(@parent.name, at.to_f - @score, Sidekiq.dump_json(@item))
end
end

2
test/test_api.rb
View file

@ -613,11 +613,13 @@ describe 'API' do
refute(retries.map { |r| r.score > (Time.now.to_f + 9) }.any?)
retries.each do |retri|
retri.reschedule(Time.now + 15) if retri.jid == 'foo1'
retri.reschedule(Time.now.to_f + 10) if retri.jid == 'foo2'
end
assert_equal 2, retries.size
assert(retries.map { |r| r.score > (Time.now.to_f + 9) }.any?)
assert(retries.map { |r| r.score > (Time.now.to_f + 14) }.any?)
end
it 'prunes processes which have died' do