lib/parallel_tests/cli.rb in parallel_tests-0.9.1 vs lib/parallel_tests/cli.rb in parallel_tests-0.9.2

@@ -26,24 +26,24 @@
       report_time_taken do
         groups = runner.tests_in_groups(options[:files], num_processes, options)
         report_number_of_tests(runner, groups)
 
         test_results = Parallel.map(groups, :in_processes => groups.size) do |group|
-          run_tests(runner, group, groups.index(group), options)
+          run_tests(runner, group, groups.index(group), num_processes, options)
         end
 
         report_results(runner, test_results)
       end
 
       abort final_fail_message(lib) if any_test_failed?(test_results)
     end
 
-    def self.run_tests(runner, group, process_number, options)
+    def self.run_tests(runner, group, process_number, num_processes, options)
       if group.empty?
         {:stdout => '', :exit_status => 0}
       else
-        runner.run_tests(group, process_number, options)
+        runner.run_tests(group, process_number, num_processes, options)
       end
     end
 
     def self.report_results(runner, test_results)
       results = runner.find_results(test_results.map { |result| result[:stdout] }*"")
@@ -126,14 +126,14 @@
 
     def self.execute_shell_command_in_parallel(command, num_processes, options)
       runs = (0...num_processes).to_a
       results = if options[:non_parallel]
         runs.map do |i|
-          ParallelTests::Test::Runner.execute_command(command, i, options)
+          ParallelTests::Test::Runner.execute_command(command, i, num_processes)
         end
       else
         Parallel.map(runs, :in_processes => num_processes) do |i|
-          ParallelTests::Test::Runner.execute_command(command, i, options)
+          ParallelTests::Test::Runner.execute_command(command, i, num_processes)
         end
       end.flatten
 
       abort if results.any? { |r| r[:exit_status] != 0 }
     end