Class: JobInvocation
Constant Summary
collapse
- CACHE_PREFIX =
"job_invocation".freeze
- FLATTENED_ERRORS_MAPPING =
{
:pattern_template_invocations => lambda do |template_invocation|
_('template') + " #{template_invocation.template.name}"
end,
}.freeze
Instance Attribute Summary collapse
Class Method Summary
collapse
Instance Method Summary
collapse
#flattened_errors, #flattened_validation_exception
Instance Attribute Details
Returns the value of attribute description_format.
68
69
70
|
# File 'app/models/job_invocation.rb', line 68
def description_format
@description_format
end
|
#start_at=(value) ⇒ Object
Sets the attribute start_at
69
70
71
|
# File 'app/models/job_invocation.rb', line 69
def start_at=(value)
@start_at = value
end
|
#start_before ⇒ Object
Returns the value of attribute start_before.
68
69
70
|
# File 'app/models/job_invocation.rb', line 68
def start_before
@start_before
end
|
Class Method Details
.search_by_recurring_logic(key, operator, value) ⇒ Object
81
82
83
84
85
86
87
|
# File 'app/models/job_invocation.rb', line 81
def self.search_by_recurring_logic(key, operator, value)
reucurring = value == 'true'
reucurring = !reucurring if operator == '<>'
not_operator = reucurring ? 'NOT' : ''
{ :conditions => sanitize_sql_for_conditions(["foreman_tasks_recurring_logics.id IS #{not_operator} NULL"]), :joins => :recurring_logic }
end
|
.search_by_status(key, operator, value) ⇒ Object
75
76
77
78
79
|
# File 'app/models/job_invocation.rb', line 75
def self.search_by_status(key, operator, value)
conditions = HostStatus::ExecutionStatus::ExecutionTaskStatusMapper.sql_conditions_for(value)
conditions[0] = "NOT (#{conditions[0]})" if operator == '<>'
{ :conditions => sanitize_sql_for_conditions(conditions), :include => :task }
end
|
Instance Method Details
#available_providers(host) ⇒ Object
TODO: determine from the host and job_invocation details
#build_notification ⇒ Object
93
94
95
96
97
98
99
100
101
102
103
104
|
# File 'app/models/job_invocation.rb', line 93
def build_notification
klass = nil
if self.remote_execution_feature && self.remote_execution_feature.notification_builder.present?
begin
klass = remote_execution_feature.notification_builder.constantize
rescue NameError => e
logger.exception "REX feature defines unknown notification builder class", e
end
end
klass ||= UINotifications::RemoteExecutionJobs::BaseJobFinish
klass.new(self)
end
|
#cancel(force = false) ⇒ Object
234
235
236
237
|
# File 'app/models/job_invocation.rb', line 234
def cancel(force = false)
method = force ? :abort : :cancel
task.send(method)
end
|
#deep_clone ⇒ Object
133
134
135
136
137
138
139
140
141
142
143
144
|
# File 'app/models/job_invocation.rb', line 133
def deep_clone
JobInvocationComposer.from_job_invocation(self).job_invocation.tap do |invocation|
invocation.task_group = JobInvocationTaskGroup.new
invocation.triggering = self.triggering
invocation.description_format = self.description_format
invocation.description = self.description
invocation.pattern_template_invocations = self.pattern_template_invocations.map(&:deep_clone)
invocation.password = self.password
invocation.key_passphrase = self.key_passphrase
invocation.sudo_password = self.sudo_password
end
end
|
#deep_clone! ⇒ Object
146
147
148
|
# File 'app/models/job_invocation.rb', line 146
def deep_clone!
deep_clone.tap(&:save!)
end
|
#failed_host_ids ⇒ Object
158
159
160
|
# File 'app/models/job_invocation.rb', line 158
def failed_host_ids
failed_hosts.pluck(:id)
end
|
#failed_hosts ⇒ Object
162
163
164
165
166
167
168
169
|
# File 'app/models/job_invocation.rb', line 162
def failed_hosts
base = targeting.hosts
if finished?
base.where.not(:id => not_failed_template_invocations.select(:host_id))
else
base.where(:id => failed_template_invocations.select(:host_id))
end
end
|
#failed_template_invocation_tasks ⇒ Object
#finished? ⇒ Boolean
239
240
241
|
# File 'app/models/job_invocation.rb', line 239
def finished?
!task.pending?
end
|
#generate_description ⇒ Object
205
206
207
208
209
210
211
212
213
214
215
216
217
|
# File 'app/models/job_invocation.rb', line 205
def generate_description
template_invocation = pattern_template_invocations.first
input_hash = template_invocation.input_values.reduce({}) do |h, v|
value = v.value
value = '*' * 3 if v.template_input.respond_to?(:hidden_value) && v.template_input.hidden_value?
h.update("%{#{v.template_input.name}}" => value)
end
input_hash.update("%{job_category}" => job_category)
input_hash.update("%{template_name}" => template_invocation.template.name)
input_hash.default = "''"
self.description = description_format.gsub(/%{[^}]+}/) { |key| input_hash[key] }
self.description = self.description[0..(JobInvocation.columns_hash['description'].limit - 1)]
end
|
#notification_recipients_ids ⇒ Object
89
90
91
|
# File 'app/models/job_invocation.rb', line 89
def notification_recipients_ids
[ self.targeting.user_id ]
end
|
#output(host) ⇒ Object
199
200
201
202
203
|
# File 'app/models/job_invocation.rb', line 199
def output(host)
return unless (task = sub_task_for_host(host)) && task.main_action && task.main_action.live_output.any?
task.main_action.live_output.first['output']
end
|
#pattern_template_invocation_for_host(host) ⇒ Object
179
180
181
182
183
184
185
186
187
188
|
# File 'app/models/job_invocation.rb', line 179
def pattern_template_invocation_for_host(host)
providers = available_providers(host)
providers.each do |provider|
pattern_template_invocations.each do |template_invocation|
if template_invocation.template.provider_type == provider
return template_invocation
end
end
end
end
|
#progress(total = nil, done = nil) ⇒ Object
returns progress in percents
119
120
121
122
123
124
125
126
127
|
# File 'app/models/job_invocation.rb', line 119
def progress(total = nil, done = nil)
if queued? || !targeting.resolved? || done == 0
0
else
total ||= targeting.hosts.count
done ||= sub_tasks.where(:result => %w(success warning error)).count
((done.to_f / total) * 100).round
end
end
|
#progress_report ⇒ Object
219
220
221
222
223
224
225
226
227
228
229
230
231
232
|
# File 'app/models/job_invocation.rb', line 219
def progress_report
map = TemplateInvocation::TaskResultMap
all_keys = (map.results | map.statuses | [:progress, :total])
if queued? || (task && task.started_at.nil?) || !targeting.resolved?
all_keys.reduce({}) do |acc, key|
acc.merge(key => 0)
end
else
counts = task.sub_tasks_counts
done = counts.values_at(*map.results).reduce(:+)
percent = progress(counts[:total], done)
counts.merge(:progress => percent, :failed => counts.values_at(*map.status_to_task_result(:failed)).reduce(:+))
end
end
|
#queued? ⇒ Boolean
129
130
131
|
# File 'app/models/job_invocation.rb', line 129
def queued?
status == HostStatus::ExecutionStatus::QUEUED
end
|
#status ⇒ Object
106
107
108
|
# File 'app/models/job_invocation.rb', line 106
def status
HostStatus::ExecutionStatus::ExecutionTaskStatusMapper.new(task).status
end
|
#status_label ⇒ Object
110
111
112
|
# File 'app/models/job_invocation.rb', line 110
def status_label
HostStatus::ExecutionStatus::ExecutionTaskStatusMapper.new(task).status_label
end
|
#sub_task_for_host(host) ⇒ Object
195
196
197
|
# File 'app/models/job_invocation.rb', line 195
def sub_task_for_host(host)
template_invocations.find_by(:host => host.id).try(:run_host_job_task)
end
|
150
151
152
|
# File 'app/models/job_invocation.rb', line 150
def to_action_input
{ :id => id, :name => job_category, :description => description }
end
|
#to_label ⇒ Object
114
115
116
|
# File 'app/models/job_invocation.rb', line 114
def to_label
description
end
|
#total_hosts_count ⇒ Object
171
172
173
174
175
176
177
|
# File 'app/models/job_invocation.rb', line 171
def total_hosts_count
if targeting.resolved?
targeting.hosts.count
else
_('N/A')
end
end
|