class SidekiqScheduler::Scheduler

def new_job(name, interval_type, config, schedule, options)
  options = options.merge({ :job => true, :tags => [name] })
  rufus_scheduler.send(interval_type, schedule, options) do |job, time|
    if job_enabled?(name)
      conf = SidekiqScheduler::Utils.sanitize_job_config(config)
      if job.is_a?(Rufus::Scheduler::CronJob)
        idempotent_job_enqueue(name, SidekiqScheduler::Utils.calc_cron_run_time(job.cron_line, time.to_t), conf)
      else
        idempotent_job_enqueue(name, time.to_t, conf)
      end
    end
  end
end