Class: Actions::RemoteExecution::RunHostsJob

Inherits:
ActionWithSubPlans
  • Object
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 



62
63
64
 
# File 'app/lib/actions/remote_execution/run_hosts_job.rb', line 62

def batch(from, size)
  hosts.offset(from).limit(size)
end

#create_sub_plans ⇒ Object 



36
37
38
39
40
41
42
43
44
45
46
 
# File 'app/lib/actions/remote_execution/run_hosts_job.rb', line 36

def create_sub_plans
  proxy_selector = RemoteExecutionProxySelector.new

  current_batch.map do |host|
    # composer creates just "pattern" for template_invocations because target is evaluated
    # during actual run (here) so we build template invocations from these patterns
    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)
  end
end

#delay(delay_options, job_invocation) ⇒ Object 



19
20
21
22
23
24
 
# File 'app/lib/actions/remote_execution/run_hosts_job.rb', line 19

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 



48
49
50
51
52
53
54
55
56
 
# File 'app/lib/actions/remote_execution/run_hosts_job.rb', line 48

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}/)
  # creating the success notification should be the very last thing this tasks do
  job_invocation.build_notification.deliver!
end

#hosts ⇒ Object 



70
71
72
 
# File 'app/lib/actions/remote_execution/run_hosts_job.rb', line 70

def hosts
  job_invocation.targeting.hosts.order(:name, :id)
end

#humanized_input ⇒ Object 



90
91
92
 
# File 'app/lib/actions/remote_execution/run_hosts_job.rb', line 90

def humanized_input
  input.fetch(:job_invocation, {}).fetch(:description, '')
end

#humanized_name ⇒ Object 



94
95
96
 
# File 'app/lib/actions/remote_execution/run_hosts_job.rb', line 94

def humanized_name
  '%s:' % _(super)
end

#job_invocation ⇒ Object 



58
59
60
 
# File 'app/lib/actions/remote_execution/run_hosts_job.rb', line 58

def job_invocation
  @job_invocation ||= JobInvocation.find(input[:job_invocation_id])
end

#plan(job_invocation) ⇒ Object 



26
27
28
29
30
31
32
33
34
 
# File 'app/lib/actions/remote_execution/run_hosts_job.rb', line 26

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

#queue ⇒ Object 



15
16
17
 
# File 'app/lib/actions/remote_execution/run_hosts_job.rb', line 15

def queue
  ForemanRemoteExecution::DYNFLOW_QUEUE
end

#rescue_strategy ⇒ Object 



82
83
84
 
# File 'app/lib/actions/remote_execution/run_hosts_job.rb', line 82

def rescue_strategy
  ::Dynflow::Action::Rescue::Skip
end

#run(event = nil) ⇒ Object 



86
87
88
 
# File 'app/lib/actions/remote_execution/run_hosts_job.rb', line 86

def run(event = nil)
  super unless event == Dynflow::Action::Skip
end

#set_up_concurrency_control(invocation) ⇒ Object 



74
75
76
77
78
79
80
 
# File 'app/lib/actions/remote_execution/run_hosts_job.rb', line 74

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 



66
67
68
 
# File 'app/lib/actions/remote_execution/run_hosts_job.rb', line 66

def total_count
  hosts.count
end