class Rufus::Scheduler::Job

def trigger(time)
  set_next_time(time)
  return if (
    opts[:overlap] == false &&
    running?
  )
  return if (
    callback(:confirm_lock, time) &&
    callback(:on_pre_trigger, time)
  ) == false
  @count += 1
  if opts[:blocking]
    do_trigger(time)
  else
    do_trigger_in_thread(time)
  end
end