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.


132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
 
# File 'lib/delayed/worker.rb', line 132

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