DelayedJob run all then exit

worker = Delayed::Worker.new(:min_priority => ENV['MIN_PRIORITY'], :max_priority => ENV['MAX_PRIORITY'])
begin
  worker.say "Starting job worker"

  trap('TERM') { worker.say 'Exiting...'; $exit = true }
  trap('INT')  { worker.say 'Exiting...'; $exit = true }

  loop do
    result = nil

    realtime = Benchmark.realtime do
      result = worker.work_off
    end

    count = result.sum

    break if $exit

    if count.zero?
      break
    else
      worker.say "#{count} jobs processed at %.4f j/s, %d failed ..." % [count / realtime, result.last]
    end

    break if $exit
  end

ensure
  Delayed::Job.clear_locks!(worker.name)
end