examples/user_recoverable_pipeline.rb in dtsato-pipeline-0.0.7 vs examples/user_recoverable_pipeline.rb in dtsato-pipeline-0.0.8

@@ -1,8 +1,6 @@
-require File.join(File.dirname(__FILE__), '..', 'init')
-require File.join(File.dirname(__FILE__), '..', 'spec', 'database_integration_helper')
-ActiveRecord::Base.logger = Logger.new(STDOUT)
+require File.join(File.dirname(__FILE__), 'helper')
 
 class Step1 < Pipeline::Stage::Base
   def run
     puts("Started step 1")
     sleep 2
@@ -26,8 +24,10 @@
   define_stages Step1 >> Step2
 end
 
 id = Pipeline.start(TwoStepPipeline.new)
 
+Delayed::Job.work_off
+
 Pipeline.resume(id)
 
-Delayed::Worker.new.start
+Delayed::Job.work_off
\ No newline at end of file