class Sidekiq::Scheduler
def self.update_schedule
def self.update_schedule if Sidekiq.redis { |r| r.scard(:schedules_changed) } > 0 logger.info 'Updating schedule' Sidekiq.reload_schedule! while schedule_name = Sidekiq.redis { |r| r.spop(:schedules_changed) } if Sidekiq.schedule.keys.include?(schedule_name) self.unschedule_job(schedule_name) self.load_schedule_job(schedule_name, Sidekiq.schedule[schedule_name]) else self.unschedule_job(schedule_name) end end logger.info 'Schedules Loaded' end end