1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
|
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
|
