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 = Sidekiq::Cron::Support.load_yaml(ERB.new(IO.read(schedule_file)).result)
        if schedule.kind_of?(Hash)
          Sidekiq::Cron::Job.load_from_hash!(schedule, source: "schedule")
        elsif schedule.kind_of?(Array)
          Sidekiq::Cron::Job.load_from_array!(schedule, source: "schedule")
        else
          raise "Not supported schedule format. Confirm your #{schedule_file}"
        end
      end
    end
  end
end

Version data entries

1 entries across 1 versions & 1 rubygems

Version	Path
sidekiq-cron-1.11.0	lib/sidekiq/cron/schedule_loader.rb