lib/paraduct/parallel_runner.rb in paraduct-0.0.1.beta10 vs lib/paraduct/parallel_runner.rb in paraduct-0.0.1.beta11
- old
+ new
@@ -16,14 +16,15 @@
START matrix test
EOS
pool = Thread.pool(Paraduct.config.max_threads)
begin
- product_variables.each do |params|
+ product_variables.each_with_index do |params, index|
runner = Paraduct::Runner.new(
script: script,
params: params,
base_job_dir: base_job_dir,
+ job_id: index + 1,
)
runner.logger.info "[START] params: #{runner.formatted_params}"
pool.process do
runner.setup_dir
begin