class Tumugi::Command::Run
Public Instance Methods
execute(dag, options={})
click to toggle source
# File lib/tumugi/command/run.rb, line 7 def execute(dag, options={}) worker_num = options[:workers] || Tumugi.config.workers executor = Tumugi::Executor::LocalExecutor.new(dag, worker_num: worker_num, run_all: options[:all]) result = executor.execute show_result_report(dag) result end
Private Instance Methods
logger()
click to toggle source
# File lib/tumugi/command/run.rb, line 23 def logger @logger ||= Tumugi::ScopedLogger.new("tumugi-run") end
show_result_report(dag)
click to toggle source
# File lib/tumugi/command/run.rb, line 17 def show_result_report(dag) reporter = Tumugi::DAGResultReporter.new report = reporter.show(dag) logger.info "Result report:\n#{report.to_s}" end