Class: Eco::API::Session::Batch::JobsGroups
Constant Summary
collapse
- DELAY_BETWEEN_GROUPS =
2
Instance Attribute Summary
#api, #config, #environment, #file_manager, #logger, #session
Class Method Summary
collapse
Instance Method Summary
collapse
#enviro=, #fatal, #fm, #mailer, #mailer?, #s3uploader, #s3uploader?, #sftp, #sftp?
Constructor Details
Returns a new instance of JobsGroups.
25
26
27
28
|
# File 'lib/eco/api/session/batch/jobs_groups.rb', line 25
def initialize(e)
super(e)
reset
end
|
Class Method Details
.counter(seconds) ⇒ Object
9
10
11
12
13
14
15
16
17
18
19
20
|
# File 'lib/eco/api/session/batch/jobs_groups.rb', line 9
def counter(seconds)
puts "\n"
while seconds + 1 > 0 do
print " Waiting #{seconds}\r"
$stdout.flush
seconds -= 1
sleep 1
end
print "#{" " * 40}"
$stdout.flush
puts ""
end
|
Instance Method Details
#[](name) ⇒ Object
53
54
55
|
# File 'lib/eco/api/session/batch/jobs_groups.rb', line 53
def [](name)
@groups[name]
end
|
#each(&block) ⇒ Object
44
45
46
47
|
# File 'lib/eco/api/session/batch/jobs_groups.rb', line 44
def each(&block)
return to_enum(:each) unless block
items.each(&block)
end
|
#empty? ⇒ Boolean
40
41
42
|
# File 'lib/eco/api/session/batch/jobs_groups.rb', line 40
def empty?
count == 0
end
|
#errors? ⇒ Boolean
120
121
122
|
# File 'lib/eco/api/session/batch/jobs_groups.rb', line 120
def errors?
any? {|group| group.errors?}
end
|
#exists?(name) ⇒ Boolean
57
58
59
|
# File 'lib/eco/api/session/batch/jobs_groups.rb', line 57
def exists?(name)
@groups.key?(name)
end
|
#find_jobs(type:) ⇒ Object
103
104
105
106
107
|
# File 'lib/eco/api/session/batch/jobs_groups.rb', line 103
def find_jobs(type:)
each_with_object([]) do |group, jbs|
jbs.concat(group.find_jobs(type: type))
end
end
|
#items ⇒ Object
49
50
51
|
# File 'lib/eco/api/session/batch/jobs_groups.rb', line 49
def items
@groups.values
end
|
Note:
- if there was post-launch callback for a
Batch::Jobs groups, it calls it.
Launches every Batch::Jobs group in the current Batch::JobGroups
90
91
92
93
94
95
96
97
98
99
100
101
|
# File 'lib/eco/api/session/batch/jobs_groups.rb', line 90
def launch(simulate: false)
@order.each_with_index do |group, idx|
if group.pending?
status[group] = group_status = group.launch(simulate: simulate)
callback = @callbacks[group]
callback.call(group, group_status) if callback
self.class.counter(delay_between_groups) if !simulate && idx < @order.length - 1
end
end
launch(simulate: simulate) if pending?
return status
end
|
#length ⇒ Object
36
37
38
|
# File 'lib/eco/api/session/batch/jobs_groups.rb', line 36
def length
count
end
|
Creates a new group of Batch::Jobs named name.
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
|
# File 'lib/eco/api/session/batch/jobs_groups.rb', line 66
def new(name, order: :last)
fatal "Can't create job group named '#{name}' because it already exists." if exists?(name)
Batch::Jobs.new(enviro, name: name).tap do |group|
@groups[name] = group
if order == :last
@order.push(group)
else
@order.unshift(group)
end
@callbacks[group] = Proc.new if block_given?
end
end
|
#pending? ⇒ Boolean
82
83
84
|
# File 'lib/eco/api/session/batch/jobs_groups.rb', line 82
def pending?
any? {|group| group.pending?}
end
|
#reset ⇒ Object
30
31
32
33
34
|
# File 'lib/eco/api/session/batch/jobs_groups.rb', line 30
def reset
@order = []
@groups = {}
@callbacks = {}
end
|
#status ⇒ Object
109
110
111
112
113
114
115
116
117
118
|
# File 'lib/eco/api/session/batch/jobs_groups.rb', line 109
def status
if block_given?
status.each do |group, group_status|
yield(group, group_status)
end
self
else
@groups_status ||= {}
end
end
|
#summary ⇒ Object
124
125
126
127
128
|
# File 'lib/eco/api/session/batch/jobs_groups.rb', line 124
def summary
[].tap do |msg|
map {|group| msg << group.summary}
end.join("\n")
end
|