lib/arc-furnace/pipeline.rb in arc-furnace-0.1.23 vs lib/arc-furnace/pipeline.rb in arc-furnace-0.1.24
- old
+ new
@@ -3,11 +3,11 @@
require 'arc-furnace/error_handler'
module ArcFurnace
class Pipeline
- eattr_accessor :sink_node, :sink_source, :intermediates_map
+ eattr_accessor :sink_node, :sink_source, :intermediates_map, :params
@intermediates_map = {}
# Ensure that subclasses don't overwrite the parent's transform
# node definitions
def self.inherited(subclass)
@@ -104,9 +104,10 @@
# Create an instance to run a transformation, passing the parameters to
# instantiate the transform instance with. The resulting class instance
# will have a single public method--#execute, which will perform the
# transformation.
def self.instance(params = {})
+ @params = params
PipelineInstance.new(self, params)
end
private