lib/paraduct/parallel_runner.rb in paraduct-0.0.1.beta13 vs lib/paraduct/parallel_runner.rb in paraduct-0.0.1.beta14

@@ -30,10 +30,11 @@
             runner.setup_dir
             begin
               stdout = runner.perform
               successful = true
             rescue Paraduct::Errors::ProcessError => e
+              runner.logger.error "exitstatus=#{e.status}, #{e.inspect}"
               stdout = e.message
               successful = false
             end
 
             runner.logger.info "[END]   params: #{runner.formatted_params}"
@@ -48,9 +49,11 @@
           end
         end
       ensure
         pool.shutdown
       end
+
+      raise Paraduct::Errors::DirtyExitError unless test_response.jobs_count == product_variables.count
 
       test_response
     end
   end
 end