class Concurrent::Supervisor

def run_worker(context) 

def run_worker(context)
  context.thread = Thread.new do
    Thread.current.abort_on_exception = false
    context.worker.run
  end
  context
end