1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
|
# frozen_string_literal: true
require 'spec_helper'
require 'parallel_tests/grouper'
require 'parallel_tests/cucumber/scenarios'
require 'tmpdir'
describe ParallelTests::Grouper do
describe '.by_steps' do
def write(file, content)
File.write(file, content)
end
it "sorts features by steps" do
tmpdir = nil
result = Dir.mktmpdir do |dir|
tmpdir = dir
write("#{dir}/a.feature", "Feature: xxx\n Scenario: xxx\n Given something")
write(
"#{dir}/b.feature",
"Feature: xxx\n Scenario: xxx\n Given something\n Scenario: yyy\n Given something"
)
write("#{dir}/c.feature", "Feature: xxx\n Scenario: xxx\n Given something")
ParallelTests::Grouper.by_steps(["#{dir}/a.feature", "#{dir}/b.feature", "#{dir}/c.feature"], 2, {})
end
# testing inside mktmpdir is always green
expect(result).to match_array(
[
["#{tmpdir}/a.feature", "#{tmpdir}/c.feature"],
["#{tmpdir}/b.feature"]
]
)
end
end
describe '.in_even_groups_by_size' do
let(:files_with_size) { { "1" => 1, "2" => 2, "3" => 3, "4" => 4, "5" => 5 } }
def call(num_groups, options = {})
ParallelTests::Grouper.in_even_groups_by_size(files_with_size, num_groups, options)
end
it "groups 1 by 1 for same groups as size" do
expect(call(5)).to eq([["5"], ["4"], ["3"], ["2"], ["1"]])
end
it "groups into even groups" do
expect(call(2)).to eq([["1", "2", "5"], ["3", "4"]])
end
it "groups into a single group" do
expect(call(1)).to eq([["1", "2", "3", "4", "5"]])
end
it "adds empty groups if there are more groups than feature files" do
expect(call(6)).to eq([["5"], ["4"], ["3"], ["2"], ["1"], []])
end
it "groups single items into first group" do
expect(call(2, single_process: [/1|2|3|4/])).to eq([["1", "2", "3", "4"], ["5"]])
end
it "groups single items into specified isolation groups" do
expect(call(3, single_process: [/1|2|3|4/], isolate_count: 2)).to eq([["1", "4"], ["2", "3"], ["5"]])
end
it "groups single items with others if there are too few" do
expect(call(2, single_process: [/1/])).to eq([["1", "3", "4"], ["2", "5"]])
end
it "groups must abort when isolate_count is out of bounds" do
expect do
call(3, single_process: [/1/], isolate_count: 3)
end.to raise_error(
"Number of isolated processes must be >= total number of processes"
)
end
context 'specify_groups' do
it "groups with one spec" do
expect(call(3, specify_groups: '1')).to eq([["1"], ["2", "5"], ["3", "4"]])
end
it "groups with multiple specs in one process" do
expect(call(3, specify_groups: '3,1')).to eq([["3", "1"], ["5"], ["2", "4"]])
end
it "groups with multiple specs and multiple processes" do
expect(call(3, specify_groups: '1,2|4')).to eq([["1", "2"], ["4"], ["3", "5"]])
end
it "aborts when number of specs is higher than number of processes" do
expect do
call(3, specify_groups: '1|2|3|4')
end.to raise_error(
"Number of processes separated by pipe must be less than or equal to the total number of processes"
)
end
it "aborts when spec passed in doesn't match existing specs" do
expect do
call(3, specify_groups: '1|2|6')
end.to raise_error(
"Could not find [\"6\"] from --specify-groups in the selected files & folders"
)
end
it "aborts when number of specs is equal to number of processes and not all specs are used" do
expect do
call(3, specify_groups: '1|2|3')
end.to raise_error(/The specs that aren't run:\n\["4", "5"\]/)
end
it "does not abort when the every single spec is specified" do
expect(call(3, specify_groups: '1,2|3,4|5')).to eq([["1", "2"], ["3", "4"], ["5"]])
end
it "can read from stdin" do
allow($stdin).to receive(:read).and_return("3,1\n")
expect(call(3, specify_groups: '-')).to eq([["3", "1"], ["5"], ["2", "4"]])
end
end
end
describe '.by_scenarios' do
let(:feature_file) { double 'file' }
it 'splits a feature into individual scenarios' do
expect(ParallelTests::Cucumber::Scenarios).to receive(:all).and_return({ 'feature_file:3' => 1 })
ParallelTests::Grouper.by_scenarios([feature_file], 1)
end
end
end
|
