test/test_sidetiq.rb in sidetiq-0.4.3 vs test/test_sidetiq.rb in sidetiq-0.5.0
- old
+ new
@@ -17,13 +17,14 @@
assert_includes workers, ScheduledWorker
assert_includes workers, BackfillWorker
end
def test_scheduled
+ client = Sidekiq::Client.new
SimpleWorker.perform_at(Time.local(2011, 1, 1, 1))
hash = SimpleWorker.jobs.first
- Sidekiq::Client.push_old(hash.merge("at" => hash["enqueued_at"]))
+ client.push_old(hash.merge("at" => hash["enqueued_at"]))
scheduled = Sidetiq.scheduled
assert_kind_of Array, scheduled
assert_kind_of Sidekiq::SortedEntry, scheduled.first
@@ -33,28 +34,30 @@
def test_scheduled_on_empty_set
assert_equal 0, Sidetiq.scheduled.length
end
def test_scheduled_given_arguments
+ client = Sidekiq::Client.new
SimpleWorker.perform_at(Time.local(2011, 1, 1, 1))
hash = SimpleWorker.jobs.first
- Sidekiq::Client.push_old(hash.merge("at" => hash["enqueued_at"]))
+ client.push_old(hash.merge("at" => hash["enqueued_at"]))
assert_equal 1, Sidetiq.scheduled(SimpleWorker).length
assert_equal 0, Sidetiq.scheduled(ScheduledWorker).length
assert_equal 1, Sidetiq.scheduled("SimpleWorker").length
assert_equal 0, Sidetiq.scheduled("ScheduledWorker").length
end
def test_scheduled_yields_each_job
+ client = Sidekiq::Client.new
SimpleWorker.perform_at(Time.local(2011, 1, 1, 1))
hash = SimpleWorker.jobs.first
- Sidekiq::Client.push_old(hash.merge("at" => hash["enqueued_at"]))
+ client.push_old(hash.merge("at" => hash["enqueued_at"]))
ScheduledWorker.perform_at(Time.local(2011, 1, 1, 1))
hash = ScheduledWorker.jobs.first
- Sidekiq::Client.push_old(hash.merge("at" => hash["enqueued_at"]))
+ client.push_old(hash.merge("at" => hash["enqueued_at"]))
jobs = []
Sidetiq.scheduled { |job| jobs << job }
assert_equal 2, jobs.length