Method: Delayed::Worker#run

Defined in:
lib/delayed/worker.rb

#run(job) ⇒ Object

[View source]

123
124
125
126
127
128
129
130
131
132
133
 
# File 'lib/delayed/worker.rb', line 123

def run(job)
  runtime =  Benchmark.realtime do
    Timeout.timeout(self.class.max_run_time.to_i) { job.invoke_job }
    job.destroy
  end
  say "#{job.name} completed after %.4f" % runtime
  return true  # did work
rescue Exception => e
  handle_failed_job(job, e)
  return false  # work failed
end