# File lib/yapra/runtime.rb, line 42 def execute_pipeline pipeline_name, command_array, data=[] self.class.logger.info("# pipeline '#{pipeline_name}' is started...") 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