class DirtyPipeline::Worker

Public Instance Methods

perform(options = {}) click to toggle source

args should contain - “enqueued_pipeline” args should contain - some args to find_subject args should contain - some args to make transition

# File lib/dirty_pipeline/worker.rb, line 11
def perform(options = {})
  pipeline_klass =
    Kernel.const_get(options.fetch("enqueued_pipeline").to_s.camelcase)
  subject = pipeline_klass.find_subject(*options.fetch("find_subject_args"))
  transaction_id = options.fetch("transaction_id")
  pipeline = pipeline_klass.new(subject, uuid: transaction_id)
  operation = options.fetch("operation")

  case operation
  when "cleanup"
    return pipeline.clean
  when "retry"
    return pipeline.retry
  end
  pipeline.call
end