class Sidekiq::Scheduler
def new_job(name, interval_type, config, args)
def new_job(name, interval_type, config, args) opts = { :job => true, :tags => [name] } rufus_scheduler.send(interval_type, *args, opts) do |job, time| idempotent_job_enqueue(name, time, sanitize_job_config(config)) if job_enabled?(name) end end