Method: Swarm::Engine::Worker#work_on

Defined in:
lib/swarm/engine/worker.rb

#work_on(queue_job) ⇒ Object

Raises:



63
64
65
66
67
68
69
70
71
72
73
 
# File 'lib/swarm/engine/worker.rb', line 63

def work_on(queue_job)
  raise NotRunningError unless running?

  command = Command.from_job(queue_job, hive: hive)
  if command.stop?
    queue.remove_worker(self, stop_job: queue_job)
    stop!
  else
    command.run!
  end
end