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

Add test for deleting a single job from a sorted set.

Browse source
This commit is contained in:
Brandon Hilkert 2012-11-26 12:56:08 -05:00
parent cbfa33cedc
commit 51569e2af1
1 changed files with 12 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

15
test/test_api.rb
View file

@ -64,6 +64,16 @@ class TestApi < MiniTest::Unit::TestCase
assert_equal 0, r.size
end
it 'can delete a single retry' do
same_time = Time.now.to_f
add_retry('bob1', same_time)
add_retry('bob2', same_time)
r = Sidekiq::RetrySet.new
assert_equal 2, r.size
r.first.delete
assert_equal 1, r.size
end
it 'can retry a retry' do
add_retry
r = Sidekiq::RetrySet.new
@ -76,9 +86,8 @@ class TestApi < MiniTest::Unit::TestCase
assert_equal 1, job['retry_count']
end
def add_retry
at = Time.now.to_f
payload = Sidekiq.dump_json('class' => 'ApiWorker', 'args' => [1, 'mike'], 'queue' => 'default', 'jid' => 'bob', 'retry_count' => 2, 'failed_at' => Time.now.utc)
def add_retry(jid = 'bob', at = Time.now.to_f)
payload = Sidekiq.dump_json('class' => 'ApiWorker', 'args' => [1, 'mike'], 'queue' => 'default', 'jid' => jid, 'retry_count' => 2, 'failed_at' => Time.now.utc)
Sidekiq.redis do |conn|
conn.zadd('retry', at.to_s, payload)
end