class Libis::Ingester::JobWorker
Public Class Methods
subject(job_id)
click to toggle source
# File lib/libis/ingester/workers/job_worker.rb, line 17 def self.subject(job_id) ::Libis::Ingester::Job.find_by(id: job_id) end
Public Instance Methods
perform(job_id, options = {})
click to toggle source
# File lib/libis/ingester/workers/job_worker.rb, line 11 def perform(job_id, options = {}) job = ::Libis::Ingester::Job.find_by(id: job_id) raise RuntimeError.new "Workflow #{job_id} not found" unless job.is_a? ::Libis::Ingester::Job job.execute options.key_symbols_to_strings(recursive: true) end