Method: Oxidized::Worker#process

Defined in:
lib/oxidized/worker.rb

#process(job) ⇒ Object 



40
41
42
43
44
45
46
47
48
49
50
51
52
53
 
# File 'lib/oxidized/worker.rb', line 40

def process job
  node = job.node
  node.last = job
  node.stats.add job
  @jobs.duration job.time
  node.running = false
  if job.status == :success
    process_success node, job
  else
    process_failure node, job
  end
rescue NodeNotFound
  Oxidized.logger.warn "#{node.group}/#{node.name} not found, removed while collecting?"
end