Contents

require 'resque/job_with_state' # in rails you would probably do this in an initializer

# sleeps for _length_ seconds updating the status every second
class SleepJob
  include Resque::Plugins::State

  def perform
    total = options.key?('length') ? options['length'].to_i : 1000
    num = 0
    while num < total
      at(num, total, "At #{num} of #{total}")
      sleep(1)
      num += 1
    end
    completed
  end
end

if __FILE__ == $PROGRAM_NAME
  # Make sure you have a worker running
  # rake -rexamples/sleep_job.rb resque:work QUEUE=statused

  # running the job
  puts 'Creating the SleepJob'
  job_id = SleepJob.create length: 100
  puts "Got back #{job_id}"

  # check the status until its complete
  while (status = Resque::Plugins::State::Hash.get(job_id)) && !status.completed? && !status.failed?
    sleep 1
    puts status.inspect
  end
end

Version data entries

4 entries across 4 versions & 1 rubygems

Version	Path
resque-state-1.1.1	examples/sleep_job.rb
resque-state-1.1.0	examples/sleep_job.rb
resque-state-1.0.4	examples/sleep_job.rb
resque-state-1.0.3	examples/sleep_job.rb