Method: Trailblazer::Activity::DSL::Linear::VariableMapping.merge_instructions_from_dsl

Defined in:
lib/trailblazer/activity/dsl/linear/feature/variable_mapping.rb

.merge_instructions_from_dsl(**options) ⇒ Object

For the input filter we

1. create a separate {Pipeline} instance {pipe}. Depending on the user's options, this might have up to four steps.
2. The {pipe} is run in a lamdba {input}, the lambda returns the pipe's ctx[:input_ctx].
3. The {input} filter in turn is wrapped into an {Activity::TaskWrap::Input} object via {#merge_instructions_for}.
4. The {TaskWrap::Input} instance is then finally placed into the taskWrap as {"task_wrap.input"}.



125
126
127
128
129
130
131
132
133
 
# File 'lib/trailblazer/activity/dsl/linear/feature/variable_mapping.rb', line 125

def merge_instructions_from_dsl(**options)
  pipeline  = DSL.pipe_for_composable_input(**options)  # FIXME: rename filters consistently
  input     = Pipe::Input.new(pipeline)

  output_pipeline = DSL.pipe_for_composable_output(**options)
  output          = Pipe::Output.new(output_pipeline)

  return input, output
end