Unlock 30% off on Manual Testing Annual Plans this Holiday Season.

Copied to Clipboard!

How to use pids method of ParallelTests Package

Best Parallel_tests_ruby code snippet using ParallelTests.pids

parallel_tests_spec.rb

Source:parallel_tests_spec.rb

...63      end64    end65    66    def with_running_processes(count, wait=0.2)67      count.times { |x| ParallelTests.pids.add(x) }68      sleep 0.169      yield70    ensure71      sleep wait # make sure the threads have finished72    end73    it "does not wait if not run in parallel" do74      expect(ParallelTests).not_to receive(:sleep)75      ParallelTests.wait_for_other_processes_to_finish76    end77    it "stops if only itself is running" do78      ParallelTests.pids.add(123)79      expect(ParallelTests).not_to receive(:sleep)80      with_running_processes(1) do81        ParallelTests.wait_for_other_processes_to_finish82      end83    end84    it "waits for other processes to finish" do85      skip if RUBY_PLATFORM == "java"86      ENV["TEST_ENV_NUMBER"] = "2"87      counter = 088      allow(ParallelTests).to receive(:sleep) do89        sleep 0.1;90        ParallelTests.pids.delete(1) if counter > 391        counter += 192      end93      with_running_processes(2, 0.6) do94        ParallelTests.wait_for_other_processes_to_finish95      end96      expect(counter).to be >= 297    end98  end99  describe ".number_of_running_processes" do100    around do |example|101      ParallelTests.with_pid_file do102        example.run103      end104    end105    106    it "is 0 for nothing" do107      expect(ParallelTests.number_of_running_processes).to eq(0)108    end109    it "is 2 when 2 are running" do110      wait = 0.2111      2.times { |x| ParallelTests.pids.add(123) }112      sleep wait / 2113      expect(ParallelTests.number_of_running_processes).to eq(2)114      sleep wait115    end116  end117  describe ".first_process?" do118    it "is first if no env is set" do119      expect(ParallelTests.first_process?).to eq(true)120    end121    it "is first if env is set to blank" do122      ENV["TEST_ENV_NUMBER"] = ""123      expect(ParallelTests.first_process?).to eq(true)124    end125    it "is first if env is set to 1" do126      ENV["TEST_ENV_NUMBER"] = "1"127      expect(ParallelTests.first_process?).to eq(true)128    end129    it "is not first if env is set to something else" do130      ENV["TEST_ENV_NUMBER"] = "2"131      expect(ParallelTests.first_process?).to eq(false)132    end133  end134  describe ".last_process?" do135    it "is last if no envs are set" do136      expect(ParallelTests.last_process?).to eq(true)137    end138    it "is last if envs are set to blank" do139      ENV["TEST_ENV_NUMBER"] = ""140      ENV["PARALLEL_TEST_GROUPS"] = ""141      expect(ParallelTests.last_process?).to eq(true)142    end143    it "is last if TEST_ENV_NUMBER is set to PARALLEL_TEST_GROUPS" do144      ENV["TEST_ENV_NUMBER"] = "4"145      ENV["PARALLEL_TEST_GROUPS"] = "4"146      expect(ParallelTests.last_process?).to eq(true)147    end148    it "is not last if TEST_ENV_NUMBER is set to else" do149      ENV["TEST_ENV_NUMBER"] = "2"150      ENV["PARALLEL_TEST_GROUPS"] = "4"151      expect(ParallelTests.first_process?).to eq(false)152    end153  end154  describe ".stop_all_processes" do155    # Process.kill on Windows doesn't work as expected. It kills all process group instead of just one process.156    it 'kills the running child process', unless: Gem.win_platform? do157      ParallelTests.with_pid_file do158        Thread.new do159          ParallelTests::Test::Runner.execute_command('sleep 3', 1, 1, {})160        end161        sleep(0.2)162        expect(ParallelTests.pids.count).to eq(1)163        ParallelTests.stop_all_processes164        sleep(0.2)165        expect(ParallelTests.pids.count).to eq(0)166      end167    end168  end169  it "has a version" do170    expect(ParallelTests::VERSION).to match(/^\d+\.\d+\.\d+/)171  end172end...

parallel_specs.rake

Source:parallel_specs.rake

...17    groups = ParallelSpecs.specs_in_groups(RAILS_ROOT, num_processes)18    num_specs = groups.sum { |g| g.size }19    puts "#{num_processes} processes for #{num_specs} specs, ~ #{num_specs / num_processes} specs per process"20    #run each of the groups21    pids = []22    read, write = IO.pipe23    groups.each_with_index do |files, process_number|24      pids << Process.fork do25        write.puts ParallelSpecs.run_tests(files, process_number)26      end27    end28    #handle user interrup (Ctrl+c)29    Signal.trap 'SIGINT' do30      STDERR.puts "Parallel specs interrupted, exiting ..."31      pids.each { |pid| Process.kill("KILL", pid) }32      exit 133    end34    #wait for processes to finish35    pids.each { Process.wait }36    #parse and print results37    write.close38    results = ParallelSpecs.find_results(read.read)39    read.close40    puts ""41    puts "Results:"42    results.each{|r| puts r}43    #report total time taken44    puts ""45    puts "Took #{Time.now - start} seconds"46    #exit with correct status code47    exit ParallelSpecs.failed?(results) ? 1 : 048  end49end50namespace :test do51  desc "run tests in parallel with test:parallel[count]"52  task :parallel, :count do |t,args|53    require File.join(File.dirname(__FILE__), '..', 'lib', 'parallel_tests')54    start = Time.now55    num_processes = (args[:count] || 2).to_i56    groups = ParallelTests.tests_in_groups(RAILS_ROOT, num_processes)57    num_specs = groups.sum { |g| g.size }58    puts "#{num_processes} processes for #{num_specs} tests, ~ #{num_specs / num_processes} tests per process"59    #run each of the groups60    pids = []61    read, write = IO.pipe62    groups.each_with_index do |files, process_number|63      pids << Process.fork do64        write.puts ParallelTests.run_tests(files, process_number)65      end66    end67    #handle user interrup (Ctrl+c)68    Signal.trap 'SIGINT' do69      STDERR.puts "Parallel tests interrupted, exiting ..."70      pids.each { |pid| Process.kill("KILL", pid) }71      exit 172    end73    #wait for processes to finish74    pids.each { Process.wait }75    #parse and print results76    write.close77    results = ParallelTests.find_results(read.read)78    read.close79    puts ""80    puts "Results:"81    results.each{|r| puts r}82    #report total time taken83    puts ""84    puts "Took #{Time.now - start} seconds"85    #exit with correct status code86    exit ParallelTests.failed?(results) ? 1 : 087  end88end...

parallel_tests@3.0.0.rbi

Source:parallel_tests@3.0.0.rbi

...9  def self.last_process?; end10  def self.now; end11  def self.number_of_running_processes; end12  def self.pid_file_path; end13  def self.pids; end14  def self.stop_all_processes; end15  def self.wait_for_other_processes_to_finish; end16  def self.with_pid_file; end17  def self.with_ruby_binary(command); end18end19class ParallelTests::CLI20  def run(argv); end21  private22  def any_test_failed?(test_results); end23  def append_test_options(options, argv); end24  def detailed_duration(seconds); end25  def execute_in_parallel(items, num_processes, options); end26  def execute_shell_command_in_parallel(command, num_processes, options); end27  def extract_file_paths(argv); end28  def extract_test_options(argv); end29  def final_fail_message; end30  def first_is_1?; end31  def handle_interrupt; end32  def load_runner(type); end33  def lock(lockfile); end34  def parse_options!(argv); end35  def report_failure_rerun_commmand(test_results, options); end36  def report_number_of_tests(groups); end37  def report_results(test_results, options); end38  def report_time_taken; end39  def reprint_output(result, lockfile); end40  def run_tests(group, process_number, num_processes, options); end41  def run_tests_in_parallel(num_processes, options); end42  def simulate_output_for_ci(simulate); end43  def use_colors?; end44end45class ParallelTests::Grouper46  def self.by_scenarios(tests, num_groups, options = _); end47  def self.by_steps(tests, num_groups, options); end48  def self.in_even_groups_by_size(items, num_groups, options = _); end49end50class ParallelTests::Pids51  def initialize(file_path); end52  def add(pid); end53  def all; end54  def count; end55  def delete(pid); end56  def file_path; end57  def mutex; end58  private59  def clear; end60  def pids; end61  def read; end62  def save; end63  def sync; end64end65ParallelTests::RUBY_BINARY = T.let(T.unsafe(nil), String)66ParallelTests::VERSION = T.let(T.unsafe(nil), String)67ParallelTests::Version = T.let(T.unsafe(nil), String)...

pids

Using AI Code Generation

1ParallelTests.pids(test_file, pid_dir, processes)2ParallelTests.pids(test_file, pid_dir, processes)3ParallelTests.pids(test_file, pid_dir, processes)4ParallelTests.pids(test_file, pid_dir, processes)

Automation Testing Tutorials

Learn to execute automation testing from scratch with LambdaTest Learning Hub. Right from setting up the prerequisites to run your first automation test, to following best practices and diving deeper into advanced test scenarios. LambdaTest Learning Hubs compile a list of step-by-step guides to help you be proficient with different test automation frameworks i.e. Selenium, Cypress, TestNG etc.