Skip to content

Commit deea948

Browse files
committed
payload class is a string not a ruby constant
Fixes resque#500
1 parent af5a9a8 commit deea948

File tree

1 file changed

+5
-5
lines changed

1 file changed

+5
-5
lines changed

test/worker_test.rb

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -385,8 +385,8 @@ def self.exception
385385

386386
test "requeue failed queue" do
387387
queue = 'good_job'
388-
Resque::Failure.create(:exception => Exception.new, :worker => Resque::Worker.new(queue), :queue => queue, :payload => {'class' => GoodJob})
389-
Resque::Failure.create(:exception => Exception.new, :worker => Resque::Worker.new(queue), :queue => 'some_job', :payload => {'class' => SomeJob})
388+
Resque::Failure.create(:exception => Exception.new, :worker => Resque::Worker.new(queue), :queue => queue, :payload => {'class' => 'GoodJob'})
389+
Resque::Failure.create(:exception => Exception.new, :worker => Resque::Worker.new(queue), :queue => 'some_job', :payload => {'class' => 'SomeJob'})
390390
Resque::Failure.requeue_queue(queue)
391391
assert Resque::Failure.all(0).has_key?('retried_at')
392392
assert !Resque::Failure.all(1).has_key?('retried_at')
@@ -395,9 +395,9 @@ def self.exception
395395
test "remove failed queue" do
396396
queue = 'good_job'
397397
queue2 = 'some_job'
398-
Resque::Failure.create(:exception => Exception.new, :worker => Resque::Worker.new(queue), :queue => queue, :payload => {'class' => GoodJob})
399-
Resque::Failure.create(:exception => Exception.new, :worker => Resque::Worker.new(queue2), :queue => queue2, :payload => {'class' => SomeJob})
400-
Resque::Failure.create(:exception => Exception.new, :worker => Resque::Worker.new(queue), :queue => queue, :payload => {'class' => GoodJob})
398+
Resque::Failure.create(:exception => Exception.new, :worker => Resque::Worker.new(queue), :queue => queue, :payload => {'class' => 'GoodJob'})
399+
Resque::Failure.create(:exception => Exception.new, :worker => Resque::Worker.new(queue2), :queue => queue2, :payload => {'class' => 'SomeJob'})
400+
Resque::Failure.create(:exception => Exception.new, :worker => Resque::Worker.new(queue), :queue => queue, :payload => {'class' => 'GoodJob'})
401401
Resque::Failure.remove_queue(queue)
402402
assert_equal queue2, Resque::Failure.all(0)['queue']
403403
assert_equal 1, Resque::Failure.count

0 commit comments

Comments
 (0)