Sha256: e78f88f00a166febf07a7c4f149c58aea847747300d8e1ac163dfc6fa4fe9b0d

Contents?: true

Size: 639 Bytes

Versions: 2

Compression:

Stored size: 639 Bytes

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