class Sidekiq::Scheduler
def enqueue_job(job_config, time=Time.now)
-
time
(Time
) -- time the job is enqueued -
job_config
(Hash
) -- the job configuration
def enqueue_job(job_config, time=Time.now) config = prepare_arguments(job_config.dup) if config.delete('include_metadata') config['args'] = arguments_with_metadata(config['args'], scheduled_at: time.to_f) end if active_job_enqueue?(config['class']) enqueue_with_active_job(config) else enqueue_with_sidekiq(config) end end