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