class Libis::Workflow::Mongoid::Job
Public Class Methods
from_hash(hash)
click to toggle source
# File lib/libis/workflow/mongoid/job.rb, line 37 def self.from_hash(hash) self.create_from_hash(hash, [:name]) do |item, cfg| item.workflow = Libis::Workflow::Mongoid::Workflow.from_hash(name: cfg.delete('workflow')) end end
Public Instance Methods
execute(opts = {})
click to toggle source
noinspection RubyStringKeysInHashInspection
Calls superclass method
# File lib/libis/workflow/mongoid/job.rb, line 65 def execute(opts = {}) opts['run_config'] ||= {} if self.log_each_run opts['run_config']['log_to_file'] = true opts['run_config']['log_level'] = self.log_level end if (run_name = opts.delete('run_name')) opts['run_config']['run_name'] = run_name end super opts end
logger()
click to toggle source
# File lib/libis/workflow/mongoid/job.rb, line 43 def logger return ::Libis::Workflow::Mongoid::Config.logger unless self.log_to_file logger = ::Logging::Repository.instance[self.name] return logger if logger unless ::Logging::Appenders[self.name] ::Logging::Appenders::RollingFile.new( self.name, filename: File.join(::Libis::Workflow::Mongoid::Config[:log_dir], "#{self.name}.{{%Y%m%d}}.log"), layout: ::Libis::Workflow::Mongoid::Config.get_log_formatter, truncate: true, age: self.log_age, keep: self.log_keep, roll_by: 'date', level: self.log_level ) end logger = ::Libis::Workflow::Mongoid::Config.logger(self.name, self.name) logger.additive = false logger end