Method: Que::Job#_run

Defined in:
lib/que/job.rb

#_run ⇒ Object 



16
17
18
19
20
21
22
23
24
25
26
27
28
 
# File 'lib/que/job.rb', line 16

def _run
  run(*attrs[:args])
  destroy unless @destroyed
rescue => error
  @_error = error
  run_error_notifier = handle_error(error)
  destroy unless @retried || @destroyed

  if run_error_notifier && Que.error_notifier
    # Protect the work loop from a failure of the error notifier.
    Que.error_notifier.call(error, @attrs) rescue nil
  end
end