lib/arc-furnace/pipeline.rb in arc-furnace-0.1.4 vs lib/arc-furnace/pipeline.rb in arc-furnace-0.1.5
- old
+ new
@@ -125,9 +125,10 @@
def run
while (row = sink_source.row)
sink_node.row(row)
end
+ intermediates_map.each { |_, instance| instance.finalize }
sink_node.finalize
end
def prepare
intermediates_map.each do |node_id, instance|