Class: Trailblazer::Activity::TaskWrap::Pipeline::Merge
- Inherits:
-
Object
- Object
- Trailblazer::Activity::TaskWrap::Pipeline::Merge
- Defined in:
- lib/trailblazer/activity/task_wrap/pipeline.rb
Overview
Merges extension_rows into the Trailblazer::Activity::TaskWrap::Pipeline instance. This is usually used in step extensions or at runtime for wrap_runtime.
Extension API
Instance Method Summary collapse
- #call(task_wrap_pipeline) ⇒ Object
-
#initialize(*extension_rows) ⇒ Merge
constructor
TODO: RENAME TO TaskWrap::Extension(::Merge).
Constructor Details
#initialize(*extension_rows) ⇒ Merge
TODO: RENAME TO TaskWrap::Extension(::Merge)
58 59 60 |
# File 'lib/trailblazer/activity/task_wrap/pipeline.rb', line 58 def initialize(*extension_rows) @extension_rows = extension_rows end |
Instance Method Details
#call(task_wrap_pipeline) ⇒ Object
62 63 64 65 |
# File 'lib/trailblazer/activity/task_wrap/pipeline.rb', line 62 def call(task_wrap_pipeline) @extension_rows.collect { |(insert_function, target_id, row)| task_wrap_pipeline = insert_function.(task_wrap_pipeline, target_id, row) } task_wrap_pipeline end |