Class: Schdlr::Dispatcher

Inherits:

Object

• Object
• Schdlr::Dispatcher

Includes:

Concurrent::Async

Defined in:

lib/schdlr/dispatcher.rb

Instance Method Summary

• #dispatch(task_spec) ⇒ Object

Instance Method Details

#dispatch(task_spec) ⇒ Object

# 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