lib/yapra/runtime.rb in yapra-0.1.1 vs lib/yapra/runtime.rb in yapra-0.1.2

@@ -1,5 +1,6 @@
+require 'logger'
 require 'yapra'
 require 'yapra/pipeline'
 require 'yapra/config'
 require 'yapra/inflector'
 
@@ -18,11 +19,14 @@
 # 
 # config_file format written in Yapra::Config document.
 class Yapra::Runtime
   attr_reader :env
   attr_reader :legacy_plugin_registry_factory
+  attr_reader :current_pipeline
   
+  @@logger = Logger.new(STDOUT)
+  
   def initialize env={}, legacy_plugin_registry_factory=nil
     @env    = env
     
     @legacy_plugin_registry_factory        = legacy_plugin_registry_factory
   end
@@ -35,12 +39,14 @@
   end
   
   # execute one pipeline.
   def execute_pipeline pipeline_name, command_array, data=[]
     self.class.logger.info("# pipeline '#{pipeline_name}' is started...")
-    pipeline = Yapra::Pipeline.new(self, pipeline_name)
+    pipeline = Yapra::Pipeline.new(pipeline_name, self)
+    @current_pipeline = pipeline
     legacy_plugin_registory = legacy_plugin_registry_factory.create(pipeline) if legacy_plugin_registry_factory
     pipeline.run(command_array, data)
+    @current_pipeline = nil
   end
   
   def self.logger
     @@logger
   end
\ No newline at end of file