Contents

require 'sidekiq'
require 'sidekiq/cron/job'
require 'sidekiq/options'

if Sidekiq.server?
  Sidekiq.configure_server do |config|
    schedule_file = Sidekiq::Options[:cron_schedule_file] || 'config/schedule.yml'

    if File.exist?(schedule_file)
      config.on(:startup) do
        schedule = YAML.load_file(schedule_file)
        if schedule.kind_of?(Hash)
          Sidekiq::Cron::Job.load_from_hash schedule
        elsif schedule.kind_of?(Array)
          Sidekiq::Cron::Job.load_from_array schedule
        else
          raise "Not supported schedule format. Confirm your #{schedule_file}"
        end
      end
    end
  end
end

Version data entries

2 entries across 2 versions & 1 rubygems

Version	Path
sidekiq-cron-1.8.0	lib/sidekiq/cron/schedule_loader.rb
sidekiq-cron-1.7.0	lib/sidekiq/cron/schedule_loader.rb