Method: Delayed::Worker#work_off

Defined in:
lib/delayed/worker.rb

#work_off(num = 100) ⇒ Object

Do num jobs and return stats on success/failure. Exit early if interrupted.


105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
 
# File 'lib/delayed/worker.rb', line 105

def work_off(num = 100)
  success, failure = 0, 0

  num.times do
    case reserve_and_run_one_job
    when true
        success += 1
    when false
        failure += 1
    else
      break  # leave if no work could be done
    end
    break if $exit # leave if we're exiting
  end

  return [success, failure]
end