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