Class: Bosh::Director::DeploymentPlan::ParallelMultiJobUpdater
- Defined in:
- lib/bosh/director/deployment_plan/multi_job_updater.rb
Instance Method Summary collapse
Instance Method Details
#run(base_job, deployment_plan, jobs) ⇒ Object
17 18 19 20 21 22 23 24 25 26 27 28 29 30 |
# File 'lib/bosh/director/deployment_plan/multi_job_updater.rb', line 17 def run(base_job, deployment_plan, jobs) base_job.logger.info("Updating jobs in parallel: #{jobs.map(&:name).join(', ')}") base_job.task_checkpoint ThreadPool.new(max_threads: jobs.size).wrap do |pool| jobs.each do |j| pool.process do base_job.logger.info("Updating job: #{j.name}") job_updater = JobUpdater.new(deployment_plan, j) job_updater.update end end end end |