Class: ParallelTests::Grouper
- Inherits:
-
Object
- Object
- ParallelTests::Grouper
- Defined in:
- lib/parallel_tests/grouper.rb
Class Method Summary collapse
- .by_steps(tests, num_groups, options) ⇒ Object
- .in_even_groups_by_size(items_with_sizes, num_groups, options = {}) ⇒ Object
Class Method Details
.by_steps(tests, num_groups, options) ⇒ Object
4 5 6 7 |
# File 'lib/parallel_tests/grouper.rb', line 4 def by_steps(tests, num_groups, ) features_with_steps = build_features_with_steps(tests, ) in_even_groups_by_size(features_with_steps, num_groups) end |
.in_even_groups_by_size(items_with_sizes, num_groups, options = {}) ⇒ Object
9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 |
# File 'lib/parallel_tests/grouper.rb', line 9 def in_even_groups_by_size(items_with_sizes, num_groups, = {}) groups = Array.new(num_groups) { {:items => [], :size => 0} } # add all files that should run in a single process to one group ([:single_process] || []).each do |pattern| matched, items_with_sizes = items_with_sizes.partition { |item, size| item =~ pattern } matched.each { |item, size| add_to_group(groups.first, item, size) } end groups_to_fill = ([:isolate] ? groups[1..-1] : groups) # add all other files largest_first(items_with_sizes).each do |item, size| smallest = smallest_group(groups_to_fill) add_to_group(smallest, item, size) end groups.map!{|g| g[:items].sort } end |