module SidekiqPipeline

Constants

VERSION

Public Class Methods

execute(params) click to toggle source

For kicking off a pipeline

# File lib/sidekiq_pipeline.rb, line 6
def self.execute(params)
  first_job = params[:pipeline].first

  klass = Object.const_get(first_job[:class])

  klass.perform_async(params)
end

Public Instance Methods

perform(params) click to toggle source

# File lib/sidekiq_pipeline.rb, line 14
def perform(params)
  # params = {
  #   pipeline: [{
  #       class: "Worker1",
  #       params: {...}
  #     },{
  #       class: "Worker2",
  #       params: {...}
  #     },...
  #   ]
  # }

  job = params["pipeline"].shift
  klass = Object.const_get(job["class"])

  klass.new.pipeline_perform(job["params"])

  if !params["pipeline"].empty?
    klass = Object.const_get(params["pipeline"].first["class"])
    klass.perform_async(params)
  end
end