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