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