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