@@ -443,7 +443,7 @@ def self.perform
443443 it "returns PID of running process" do
444444 assert_equal @worker . to_s . split ( ":" ) [ 1 ] . to_i , @worker . pid
445445 end
446-
446+
447447 it "requeue failed queue" do
448448 queue = 'good_job'
449449 Resque ::Failure . create ( :exception => Exception . new , :worker => Resque ::Worker . new ( queue ) , :queue => queue , :payload => { 'class' => 'GoodJob' } )
@@ -479,11 +479,11 @@ def self.perform
479479 $CAPTURED_WORKER = worker
480480 end
481481
482- @worker . instance_variable_set ( :@paused , true )
482+ @worker . pause_processing
483483
484484 assert !$BEFORE_PAUSE_CALLED
485485
486- t = Thread . start { sleep ( 1 ) ; Process . kill ( 'CONT' , @worker . pid ) }
486+ t = Thread . start { sleep ( 0. 1) ; Process . kill ( 'CONT' , @worker . pid ) }
487487
488488 @worker . work ( 0 )
489489
@@ -502,11 +502,11 @@ def self.perform
502502 $CAPTURED_WORKER = worker
503503 end
504504
505- @worker . instance_variable_set ( :@paused , true )
505+ @worker . pause_processing
506506
507507 assert !$AFTER_PAUSED_CALLED
508508
509- t = Thread . start { sleep ( 1 ) ; Process . kill ( 'CONT' , @worker . pid ) }
509+ t = Thread . start { sleep ( 0. 1) ; Process . kill ( 'CONT' , @worker . pid ) }
510510
511511 @worker . work ( 0 )
512512
0 commit comments