class LIBIS::Workflow::Worker

Attributes

options[RW]
workflow[R]
workflow_name[RW]

Public Class Methods

new(workflow_name, options = {}) click to toggle source
# File lib/libis/workflow/worker.rb, line 14
def initialize(workflow_name, options = {})

  @workflow_name = workflow_name
  log_path = options.delete :log_path
  if log_path
    Config.logger = ::Logger.new(
        File.join(log_path, "#{workflow_name}.log"),
        (options.delete(:log_shift_age) || 'daily'),
        (options.delete(:log_shift_size) || 1024 ** 2)
    )
    Config.logger.formatter = ::Logger::Formatter.new
    Config.logger.level = ::Logger::DEBUG
  end

  @workflow = Workflow.new workflow_name

end

Public Instance Methods

run(options = {}) click to toggle source
# File lib/libis/workflow/worker.rb, line 37
def run(options = {})
  options[:interactive] = false
  @workflow.run options
end
start(options = {}) click to toggle source
# File lib/libis/workflow/worker.rb, line 32
def start(options = {})
  options[:interactive] = true
  @workflow.run options
end