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