26 lines
612 B
Ruby
26 lines
612 B
Ruby
|
class Jobs::Onceoff < Jobs::Base
|
||
|
|
sidekiq_options retry: false
|
||
|
|
|
||
|
|
def self.name_for(klass)
|
||
|
|
klass.name.sub(/^Jobs\:\:/, '')
|
||
|
|
end
|
||
|
|
|
||
|
|
# Pass `force: true` to force it happen again
|
||
|
|
def execute(args)
|
||
|
|
job_name = self.class.name_for(self.class)
|
||
|
|
|
||
|
|
if args[:force] || !OnceoffLog.where(job_name: job_name).exists?
|
||
|
|
execute_onceoff(args)
|
||
|
|
OnceoffLog.create(job_name: job_name)
|
||
|
|
end
|
||
|
|
end
|
||
|
|
|
||
|
|
def self.enqueue_all
|
||
|
|
ObjectSpace.each_object(Class).select { |klass| klass < self }.each do |klass|
|
||
|
|
job_name = name_for(klass).underscore.to_sym
|
||
|
|
Jobs.enqueue(job_name)
|
||
|
|
end
|
||
|
|
end
|
||
|
|
|
||
|
|
end
|