lib/paraduct/parallel_runner.rb in paraduct-1.0.0.beta6 vs lib/paraduct/parallel_runner.rb in paraduct-1.0.0
- old
+ new
@@ -21,11 +21,11 @@
begin
product_variables.each_with_index do |params, index|
runner = Paraduct::Runner.new(
params: params,
base_job_dir: base_job_dir,
- job_id: index + 1,
+ job_id: index + 1
)
pool.process do
runner.logger.info "[START] params: #{runner.formatted_params}"
runner.setup_dir if Paraduct.config.enable_rsync?
@@ -42,11 +42,11 @@
test_response.jobs_push(
job_name: runner.job_name,
params: runner.params,
formatted_params: runner.formatted_params,
successful: successful,
- stdout: stdout,
+ stdout: stdout
)
end
end
ensure
pool.shutdown
@@ -65,10 +65,10 @@
rescue Paraduct::Errors::ProcessError => e
runner.logger.error "exitstatus=#{e.status}, #{e.inspect}"
[e.message, false]
- rescue Exception => e
+ rescue => e
runner.logger.error "Unknown error: #{e.inspect}"
runner.logger.error e.backtrace.join("\n")
[nil, false]
end
end