class Libis::Workflow::Mongoid::Run
Public Instance Methods
close_logger()
click to toggle source
# File lib/libis/workflow/mongoid/run.rb, line 78 def close_logger return unless self.log_to_file ::Logging::Appenders[self.name].close ::Logging::Appenders.remove(self.name) ::Logging::Repository.instance.delete(self.name) end
logger()
click to toggle source
# File lib/libis/workflow/mongoid/run.rb, line 57 def logger unless self.log_to_file return self.job.logger end logger = ::Logging::Repository.instance[self.name] return logger if logger unless ::Logging::Appenders[self.name] self.log_filename ||= File.join(::Libis::Workflow::Mongoid::Config[:log_dir], "#{self.name}-#{self.id}.log") ::Logging::Appenders::File.new( self.name, filename: self.log_filename, layout: ::Libis::Workflow::Mongoid::Config.get_log_formatter, level: self.log_level ) end logger = ::Libis::Workflow::Mongoid::Config.logger(self.name, self.name) logger.additive = false logger.level = self.log_level logger end
name()
click to toggle source
# File lib/libis/workflow/mongoid/run.rb, line 85 def name parts = [self.job.name] parts << self.run_name unless self.run_name.blank? parts << self.id.generation_time.strftime('%Y%m%d-%H%M%S') parts << self.id.to_s[8..-1] if self.run_name.blank? parts.join('-') rescue self.id.to_s end
rm_log()
click to toggle source
# File lib/libis/workflow/mongoid/run.rb, line 31 def rm_log log_file = self.log_filename FileUtils.rm(log_file) if log_file && !log_file.blank? && File.exist?(log_file) end
rm_workdir()
click to toggle source
# File lib/libis/workflow/mongoid/run.rb, line 36 def rm_workdir workdir = self.work_dir FileUtils.rmtree workdir if workdir && !workdir.blank? && Dir.exist?(workdir) end
run(action = :run)
click to toggle source
Calls superclass method
# File lib/libis/workflow/mongoid/run.rb, line 48 def run(action = :run) self.start_date = Time.now self.tasks = [] super action self.reload self.reload_relations close_logger end
work_dir()
click to toggle source
# File lib/libis/workflow/mongoid/run.rb, line 41 def work_dir # noinspection RubyResolve dir = File.join(Libis::Workflow::Config.workdir, self.id) FileUtils.mkpath dir unless Dir.exist?(dir) dir end