lib/sidekiq-scheduler/rufus_utils.rb
require 'sidekiq-scheduler/utils'
module SidekiqScheduler
class RufusUtils
# Normalizes schedule options to rufus scheduler options
#
# @param options [String, Array]
#
# @return [Array]
#
# @example
# normalize_schedule_options('15m') => ['15m', {}]
# normalize_schedule_options(['15m']) => ['15m', {}]
# normalize_schedule_options(['15m', first_in: '5m']) => ['15m', { first_in: '5m' }]
def self.normalize_schedule_options(options)
schedule, opts = options
if !opts.is_a?(Hash)
opts = {}
end
opts = SidekiqScheduler::Utils.symbolize_keys(opts)
return schedule, opts
end
end
end