class Schdlr::Dispatcher

Public Instance Methods

dispatch(task_spec) click to toggle source
# File lib/schdlr/dispatcher.rb, line 5
def dispatch(task_spec)
  _, _, _, task = *task_spec
  worker = YAML.load(task)
  worker.perform
  return task_spec
rescue => ex
  raise JobFailed.new(task_spec, ex.message)
end