Method: Trailblazer::Activity::TaskWrap::Pipeline#call

Defined in:
lib/trailblazer/activity/task_wrap/pipeline.rb

#call(wrap_ctx, original_args) ⇒ Object

Execute the pipeline and call all its steps, passing around the wrap_ctx.



15
16
17
18
19
 
# File 'lib/trailblazer/activity/task_wrap/pipeline.rb', line 15

def call(wrap_ctx, original_args)
  @sequence.each { |(_id, task)| wrap_ctx, original_args = task.(wrap_ctx, original_args) }

  return wrap_ctx, original_args
end