summaryrefslogtreecommitdiff
path: root/lib
diff options
context:
space:
mode:
authorMatija Čupić <matteeyah@gmail.com>2018-10-31 15:27:39 +0100
committerMatija Čupić <matteeyah@gmail.com>2018-10-31 15:27:51 +0100
commit8f8a89f98edc4cb901f4107cbf38288576849d9e (patch)
tree01fd75d067c8f43bfee7a0a80b63cf2814971bf3 /lib
parent94923328fdf2904e5a31ad8b9c40adcf15428bb2 (diff)
downloadgitlab-ce-8f8a89f98edc4cb901f4107cbf38288576849d9e.tar.gz
Implement POC config based parallelization
Diffstat (limited to 'lib')
-rw-r--r--lib/gitlab/ci/config/entry/jobs.rb10
-rw-r--r--lib/gitlab/ci/yaml_processor.rb1
2 files changed, 11 insertions, 0 deletions
diff --git a/lib/gitlab/ci/config/entry/jobs.rb b/lib/gitlab/ci/config/entry/jobs.rb
index 96b6f2e5d6c..fc4b8637ee2 100644
--- a/lib/gitlab/ci/config/entry/jobs.rb
+++ b/lib/gitlab/ci/config/entry/jobs.rb
@@ -29,6 +29,16 @@ module Gitlab
# rubocop: disable CodeReuse/ActiveRecord
def compose!(deps = nil)
super do
+ @config = @config.map do |name, config|
+ total = config[:parallel]
+ if total
+ Array.new(total) { { name => config } }
+ .each_with_index { |build, idx| build["#{name} #{idx + 1}/#{total}".to_sym] = build.delete(name) }
+ else
+ { name => config }
+ end
+ end.flatten.reduce(:merge)
+
@config.each do |name, config|
node = hidden?(name) ? Entry::Hidden : Entry::Job
diff --git a/lib/gitlab/ci/yaml_processor.rb b/lib/gitlab/ci/yaml_processor.rb
index a427aa30683..612d733ad49 100644
--- a/lib/gitlab/ci/yaml_processor.rb
+++ b/lib/gitlab/ci/yaml_processor.rb
@@ -50,6 +50,7 @@ module Gitlab
after_script: job[:after_script],
environment: job[:environment],
retry: job[:retry],
+ parallel: job[:parallel],
start_in: job[:start_in]
}.compact }
end