class Yapra::Runtime
How to use¶ ↑
require 'yapra/runtime' require 'yapra/config' config = YAML.load(config_file) config = Yapra::Config.new(config) Yapra::Runtime.logger = Logger.new(STDOUT) yapra = Yapra::Runtime.new(config.env) yapra.execute(config.pipeline_commands)
config_file format written in Yapra::Config document.
Attributes
current_pipeline[R]
env[R]
legacy_plugin_registry_factory[R]
Public Class Methods
logger()
click to toggle source
# File lib/yapra/runtime.rb, line 51 def self.logger @@logger end
logger=(logger)
click to toggle source
# File lib/yapra/runtime.rb, line 55 def self.logger=logger @@logger = logger end
new(env={})
click to toggle source
# File lib/yapra/runtime.rb, line 28 def initialize env={}, legacy_plugin_registry_factory=nil @env = env @legacy_plugin_registry_factory = legacy_plugin_registry_factory end
Public Instance Methods
execute(pipeline_commands)
click to toggle source
execute pipelines from commands.
# File lib/yapra/runtime.rb, line 35 def execute pipeline_commands pipeline_commands.each do |k, v| execute_pipeline k, v, [] end end
execute_pipeline(pipeline_name, command_array, data=[])
click to toggle source
execute one pipeline.
# 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