Parent

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

[Validate]

Generated with the Darkfish Rdoc Generator 2.