class Rufus::Scheduler

def join
  fail NotRunningError.new(
    'cannot join scheduler that is not running'
  ) unless @thread
  @thread.join
end