Class: Actions::RemoteExecution::RunHostsJob
- Inherits:
-
ActionWithSubPlans
- Object
- ActionWithSubPlans
- Actions::RemoteExecution::RunHostsJob
show all
- Includes:
- Actions::RecurringAction, Dynflow::Action::WithBulkSubPlans, Dynflow::Action::WithPollingSubPlans
- Defined in:
- app/lib/actions/remote_execution/run_hosts_job.rb
Defined Under Namespace
Classes: CheckOnProxyActions
Instance Method Summary
collapse
Instance Method Details
#batch(from, size) ⇒ Object
63
64
65
|
# File 'app/lib/actions/remote_execution/run_hosts_job.rb', line 63
def batch(from, size)
hosts.offset(from).limit(size)
end
|
#create_sub_plans ⇒ Object
37
38
39
40
41
42
43
44
45
46
47
|
# File 'app/lib/actions/remote_execution/run_hosts_job.rb', line 37
def create_sub_plans
proxy_selector = RemoteExecutionProxySelector.new
current_batch.map do |host|
template_invocation = job_invocation.pattern_template_invocation_for_host(host).deep_clone
template_invocation.host_id = host.id
trigger(RunHostJob, job_invocation, host, template_invocation, proxy_selector, { :use_concurrency_control => uses_concurrency_control })
end
end
|
#delay(delay_options, job_invocation) ⇒ Object
20
21
22
23
24
25
|
# File 'app/lib/actions/remote_execution/run_hosts_job.rb', line 20
def delay(delay_options, job_invocation)
task.add_missing_task_groups(job_invocation.task_group)
job_invocation.targeting.resolve_hosts! if job_invocation.targeting.static? && !job_invocation.targeting.resolved?
input.update :job_invocation => job_invocation.to_action_input
super delay_options, job_invocation
end
|
#finalize ⇒ Object
49
50
51
52
53
54
55
56
57
|
# File 'app/lib/actions/remote_execution/run_hosts_job.rb', line 49
def finalize
job_invocation.password = job_invocation.key_passphrase = job_invocation.sudo_password = nil
job_invocation.save!
Rails.logger.debug "cleaning cache for keys that begin with 'job_invocation_#{job_invocation.id}'"
Rails.cache.delete_matched(/\A#{JobInvocation::CACHE_PREFIX}_#{job_invocation.id}/)
job_invocation.build_notification.deliver!
end
|
#hosts ⇒ Object
71
72
73
|
# File 'app/lib/actions/remote_execution/run_hosts_job.rb', line 71
def hosts
job_invocation.targeting.hosts.order("#{TargetingHost.table_name}.id")
end
|
91
92
93
|
# File 'app/lib/actions/remote_execution/run_hosts_job.rb', line 91
def humanized_input
input.fetch(:job_invocation, {}).fetch(:description, '')
end
|
#humanized_name ⇒ Object
95
96
97
|
# File 'app/lib/actions/remote_execution/run_hosts_job.rb', line 95
def humanized_name
'%s:' % _(super)
end
|
#job_invocation ⇒ Object
59
60
61
|
# File 'app/lib/actions/remote_execution/run_hosts_job.rb', line 59
def job_invocation
@job_invocation ||= JobInvocation.find(input[:job_invocation_id])
end
|
#plan(job_invocation) ⇒ Object
27
28
29
30
31
32
33
34
35
|
# File 'app/lib/actions/remote_execution/run_hosts_job.rb', line 27
def plan(job_invocation)
job_invocation.task_group.save! if job_invocation.task_group.try(:new_record?)
task.add_missing_task_groups(job_invocation.task_group) if job_invocation.task_group
action_subject(job_invocation)
job_invocation.targeting.resolve_hosts! if job_invocation.targeting.dynamic? || !job_invocation.targeting.resolved?
set_up_concurrency_control job_invocation
input.update(:job_category => job_invocation.job_category)
plan_self(:job_invocation_id => job_invocation.id)
end
|
#rescue_strategy ⇒ Object
83
84
85
|
# File 'app/lib/actions/remote_execution/run_hosts_job.rb', line 83
def rescue_strategy
::Dynflow::Action::Rescue::Skip
end
|
#run(event = nil) ⇒ Object
87
88
89
|
# File 'app/lib/actions/remote_execution/run_hosts_job.rb', line 87
def run(event = nil)
super unless event == Dynflow::Action::Skip
end
|
#set_up_concurrency_control(invocation) ⇒ Object
75
76
77
78
79
80
81
|
# File 'app/lib/actions/remote_execution/run_hosts_job.rb', line 75
def set_up_concurrency_control(invocation)
limit_concurrency_level invocation.concurrency_level unless invocation.concurrency_level.nil?
unless invocation.time_span.nil?
distribute_over_time(invocation.time_span,
invocation.targeting.hosts.count)
end
end
|
#total_count ⇒ Object
67
68
69
|
# File 'app/lib/actions/remote_execution/run_hosts_job.rb', line 67
def total_count
hosts.count
end
|