lib/paraduct/parallel_runner.rb in paraduct-0.0.3 vs lib/paraduct/parallel_runner.rb in paraduct-1.0.0.beta1

@@ -6,11 +6,11 @@
     # @param script            [String, Array<String>] script file, script(s)
     # @param product_variables [Array<Hash{String => String}>]
     # @return [Paraduct::TestResponse]
     def self.perform_all(script, product_variables)
       test_response = Paraduct::TestResponse.new
-      base_job_dir = Paraduct.config.work_dir
+      base_job_dir = Paraduct.config.base_job_dir
       FileUtils.mkdir_p(base_job_dir) unless base_job_dir.exist?
 
       Paraduct.logger.info <<-EOS
 ======================================================
 START matrix test
@@ -25,10 +25,10 @@
             base_job_dir: base_job_dir,
             job_id:       index + 1,
           )
           pool.process do
             runner.logger.info "[START] params: #{runner.formatted_params}"
-            runner.setup_dir
+            runner.setup_dir if Paraduct.config.enable_rsync?
             begin
               stdout = runner.perform
               successful = true
             rescue Paraduct::Errors::ProcessError => e
               runner.logger.error "exitstatus=#{e.status}, #{e.inspect}"