Class: Pipely::RunsReport

Inherits:
Struct
  • Object
show all
Defined in:
lib/pipely/runs_report.rb

Overview

Prints a CLI report of the execution status of a live pipeline

Instance Attribute Summary collapse

Instance Method Summary collapse

Instance Attribute Details

#task_states_by_scheduled_start ⇒ Object

Returns the value of attribute task_states_by_scheduled_start

Returns:

  • (Object) —

    the current value of task_states_by_scheduled_start



4
5
6
 
# File 'lib/pipely/runs_report.rb', line 4

def task_states_by_scheduled_start
  @task_states_by_scheduled_start
end

Instance Method Details



6
7
8
9
10
11
12
13
14
15
16
17
18
 
# File 'lib/pipely/runs_report.rb', line 6

def print
  return false unless $stdout.tty?

  task_states_by_scheduled_start.each do |scheduled_start, task_states|
    task_states.to_a.sort_by(&:first).each do |task_name, attributes|
      current_state = attributes[:execution_state]

      puts task_name.ljust(55) +
        "scheduled_start: #{scheduled_start}\t\t" +
        "current_state: #{current_state}"
    end
  end
end