Change flaky test runner worker processes from 8 to 12

brianseeders · brianseeders · commit 5d12ed9343be · 2019-10-29T14:01:40.000-04:00
diff --git a/.ci/Jenkinsfile_flaky b/.ci/Jenkinsfile_flaky
@@ -79,9 +79,9 @@ def getWorkerFromParams(isXpack, job, ciGroup) {
   }
 }
 
-def getWorkerMap(agentNumber, numberOfExecutions, worker, workerFailures, maxWorkers = 8) {
+def getWorkerMap(agentNumber, numberOfExecutions, worker, workerFailures, maxWorkerProcesses = 12) {
   def workerMap = [:]
-  def numberOfWorkers = Math.min(numberOfExecutions, maxWorkers)
+  def numberOfWorkers = Math.min(numberOfExecutions, maxWorkerProcesses)
 
   for(def i = 1; i <= numberOfWorkers; i++) {
     def workerExecutions = numberOfExecutions/numberOfWorkers + (i <= numberOfExecutions%numberOfWorkers ? 1 : 0)
@@ -110,8 +110,8 @@ def getWorkerMap(agentNumber, numberOfExecutions, worker, workerFailures, maxWor
 }
 
 def getAgentCount(executions) {
-  // Increase agent count every 40 workers, up to 3 agents maximum
-  return Math.min(3, 1 + floor(executions/40))
+  // Increase agent count every 24 worker processess, up to 3 agents maximum
+  return Math.min(3, 1 + floor(executions/24))
 }
 
 def trunc(str, length) {

Original file line number	Diff line number	Diff line change
`@@ -79,9 +79,9 @@ def getWorkerFromParams(isXpack, job, ciGroup) {`
`79`	`79`	`}`
`80`	`80`	`}`
`81`	`81`
`82`		`-def getWorkerMap(agentNumber, numberOfExecutions, worker, workerFailures, maxWorkers = 8) {`
	`82`	`+def getWorkerMap(agentNumber, numberOfExecutions, worker, workerFailures, maxWorkerProcesses = 12) {`
`83`	`83`	`def workerMap = [:]`
`84`		`- def numberOfWorkers = Math.min(numberOfExecutions, maxWorkers)`
	`84`	`+ def numberOfWorkers = Math.min(numberOfExecutions, maxWorkerProcesses)`
`85`	`85`
`86`	`86`	`for(def i = 1; i <= numberOfWorkers; i++) {`
`87`	`87`	`def workerExecutions = numberOfExecutions/numberOfWorkers + (i <= numberOfExecutions%numberOfWorkers ? 1 : 0)`
`@@ -110,8 +110,8 @@ def getWorkerMap(agentNumber, numberOfExecutions, worker, workerFailures, maxWor`
`110`	`110`	`}`
`111`	`111`
`112`	`112`	`def getAgentCount(executions) {`
`113`		`- // Increase agent count every 40 workers, up to 3 agents maximum`
`114`		`- return Math.min(3, 1 + floor(executions/40))`
	`113`	`+ // Increase agent count every 24 worker processess, up to 3 agents maximum`
	`114`	`+ return Math.min(3, 1 + floor(executions/24))`
`115`	`115`	`}`
`116`	`116`
`117`	`117`	`def trunc(str, length) {`