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