class Sidekiq::Cron::Poller

The Poller checks Redis every N seconds for sheduled cron jobs

Public Instance Methods

enqueue() click to toggle source
# File lib/sidekiq/cron/poller.rb, line 10
def enqueue
  Sidekiq::Cron::Job.all.each do |job|
    enqueue_job(job)
  end
rescue => ex
  # Most likely a problem with redis networking.
  # Punt and try again at the next interval
  logger.error ex.message
  logger.error ex.backtrace.first
end

Private Instance Methods

enqueue_job(job) click to toggle source
# File lib/sidekiq/cron/poller.rb, line 23
def enqueue_job(job)
  job.test_and_enque_for_time! Time.now if job && job.valid?
rescue => ex
  # problem somewhere in one job
  logger.error "CRON JOB: #{ex.message}"
  logger.error "CRON JOB: #{ex.backtrace.first}"
end