Module: Rukawa::Overview

Defined in:
lib/rukawa/overview.rb

Class Method Summary collapse

Class Method Details

.display_running_status(root_job_net) ⇒ Object 



37
38
39
40
41
42
43
44
45
46
47
48
49
50
 
# File 'lib/rukawa/overview.rb', line 37

def display_running_status(root_job_net)
  context = root_job_net.context
  table = Terminal::Table.new(headings: [
    "Job",
    "Status",
    "Elapsed Time",
    "Resource Count (#{context.semaphore.available_permits}/#{context.concurrency})",
  ]) do |t|
    root_job_net.each_with_index do |j|
      running_table_row(t, j)
    end
  end
  puts table
end

.list_job ⇒ Object 



15
16
17
18
19
20
21
22
23
24
 
# File 'lib/rukawa/overview.rb', line 15

def list_job
  header = ["Job", "Desc"]
  table = Terminal::Table.new headings: header do |t|
    Job.descendants.each do |job|
      row = [Paint[job.name, :bold, :underline], job.desc]
      t << row
    end
  end
  puts table
end

.list_job_net(with_jobs: false) ⇒ Object 



4
5
6
7
8
9
10
11
12
13
 
# File 'lib/rukawa/overview.rb', line 4

def list_job_net(with_jobs: false)
  header = ["Job", "Desc"]
  header << "Dependencies" if with_jobs
  table = Terminal::Table.new headings: header do |t|
    JobNet.descendants.each do |job_net|
      list_table_row(t, job_net, with_jobs: with_jobs)
    end
  end
  puts table
end

.list_table_row(table, job_net, with_jobs: false) ⇒ Object 



26
27
28
29
30
31
32
33
34
35
 
# File 'lib/rukawa/overview.rb', line 26

def list_table_row(table, job_net, with_jobs: false)
  row = [Paint[job_net.name, :bold, :underline], job_net.desc]
  row << "" if with_jobs
  table << row
  if with_jobs
    job_net.dependencies.each do |inner_j, deps|
      table << [Paint["#{"  "}#{inner_j.name}"], inner_j.desc, deps.join(", ")]
    end
  end
end

.running_table_row(table, job, level = 0) ⇒ Object 



52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
 
# File 'lib/rukawa/overview.rb', line 52

def running_table_row(table, job, level = 0)
  if job.is_a?(JobNet)
    table << [
      Paint["#{"  " * level}#{job.class}", :bold, :underline],
      Paint[job.state.colored, :bold, :underline],
      Paint[job.formatted_elapsed_time_from, :bold, :underline],
      "",
    ]
    job.each do |inner_j|
      running_table_row(table, inner_j, level + 1)
    end
  else
    table << [Paint["#{"  " * level}#{job.class}", :bold], job.state.colored, job.formatted_elapsed_time_from, job.resource_count]
  end
end