class Sidekiq::Cron::ScheduleLoader
Public Instance Methods
Source
# File lib/sidekiq/cron/schedule_loader.rb, line 14 def has_schedule_file? File.exist?(schedule_file_name) end
Source
# File lib/sidekiq/cron/schedule_loader.rb, line 4 def load_schedule if schedule.is_a?(Hash) Sidekiq::Cron::Job.load_from_hash!(schedule, source: "schedule") elsif schedule.is_a?(Array) Sidekiq::Cron::Job.load_from_array!(schedule, source: "schedule") else raise "Not supported schedule format. Confirm your #{schedule_file_name}" end end
Private Instance Methods
Source
# File lib/sidekiq/cron/schedule_loader.rb, line 24 def rendered_schedule_template ERB.new(schedule_file_content).result end
Source
# File lib/sidekiq/cron/schedule_loader.rb, line 20 def schedule @schedule ||= Sidekiq::Cron::Support.load_yaml(rendered_schedule_template) end
Source
# File lib/sidekiq/cron/schedule_loader.rb, line 28 def schedule_file_content IO.read(schedule_file_name) end
Source
# File lib/sidekiq/cron/schedule_loader.rb, line 32 def schedule_file_name @schedule_file_name ||= yml_to_yaml_unless_file_exists(schedule_file_name_from_config) end
Source
# File lib/sidekiq/cron/schedule_loader.rb, line 36 def schedule_file_name_from_config Sidekiq::Cron.configuration.cron_schedule_file end
Source
# File lib/sidekiq/cron/schedule_loader.rb, line 40 def yml_to_yaml_unless_file_exists(file_name) if File.exist?(file_name) file_name else file_name.sub(/\.yml$/, ".yaml") end end