@@ -21,53 +21,47 @@ def workerFailures = []
2121currentBuild. displayName + = trunc(" ${ params.GITHUB_OWNER} :${ params.branch_specifier} " , 24 )
2222currentBuild. description = " ${ params.CI_GROUP} <br />Agents: ${ AGENT_COUNT} <br />Executions: ${ params.NUMBER_EXECUTIONS} "
2323
24- stage(" Kibana Pipeline" ) {
25- timeout(time : 180 , unit : ' MINUTES' ) {
26- timestamps {
27- ansiColor(' xterm' ) {
28- def agents = [:]
29- for (def agentNumber = 1 ; agentNumber <= AGENT_COUNT ; agentNumber++ ) {
30- def agentNumberInside = agentNumber
31- def agentExecutions = floor(EXECUTIONS / AGENT_COUNT ) + (agentNumber <= EXECUTIONS % AGENT_COUNT ? 1 : 0 )
32- agents[" agent-${ agentNumber} " ] = {
33- catchError {
34- print " Agent ${ agentNumberInside} - ${ agentExecutions} executions"
35-
36- kibanaPipeline. withWorkers(' flaky-test-runner' , {
37- if (NEED_BUILD ) {
38- if (! IS_XPACK ) {
39- kibanaPipeline. buildOss()
40- if (CI_GROUP == ' 1' ) {
41- runbld(" ./test/scripts/jenkins_build_kbn_tp_sample_panel_action.sh" , " Build kbn tp sample panel action for ciGroup1" )
42- }
43- } else {
44- kibanaPipeline. buildXpack()
45- }
46- }
47- }, getWorkerMap(agentNumberInside, agentExecutions, worker, workerFailures))()
24+ kibanaPipeline(timeoutMinutes : 180 ) {
25+ def agents = [:]
26+ for (def agentNumber = 1 ; agentNumber <= AGENT_COUNT ; agentNumber++ ) {
27+ def agentNumberInside = agentNumber
28+ def agentExecutions = floor(EXECUTIONS / AGENT_COUNT ) + (agentNumber <= EXECUTIONS % AGENT_COUNT ? 1 : 0 )
29+ agents[" agent-${ agentNumber} " ] = {
30+ catchErrors {
31+ print " Agent ${ agentNumberInside} - ${ agentExecutions} executions"
32+
33+ workers. functional(' flaky-test-runner' , {
34+ if (NEED_BUILD ) {
35+ if (! IS_XPACK ) {
36+ kibanaPipeline. buildOss()
37+ if (CI_GROUP == ' 1' ) {
38+ runbld(" ./test/scripts/jenkins_build_kbn_sample_panel_action.sh" , " Build kbn tp sample panel action for ciGroup1" )
39+ }
40+ } else {
41+ kibanaPipeline. buildXpack()
4842 }
4943 }
50- }
44+ }, getWorkerMap(agentNumberInside, agentExecutions, worker, workerFailures))()
45+ }
46+ }
47+ }
5148
52- parallel(agents)
49+ parallel(agents)
5350
54- currentBuild. description + = " , Failures: ${ workerFailures.size()} "
51+ currentBuild. description + = " , Failures: ${ workerFailures.size()} "
5552
56- if (workerFailures. size() > 0 ) {
57- print " There were ${ workerFailures.size()} test suite failures."
58- print " The executions that failed were:"
59- print workerFailures. join(" \n " )
60- print " Please check 'Test Result' and 'Pipeline Steps' pages for more info"
61- }
62- }
63- }
53+ if (workerFailures. size() > 0 ) {
54+ print " There were ${ workerFailures.size()} test suite failures."
55+ print " The executions that failed were:"
56+ print workerFailures. join(" \n " )
57+ print " Please check 'Test Result' and 'Pipeline Steps' pages for more info"
6458 }
6559}
6660
6761def getWorkerFromParams (isXpack , job , ciGroup ) {
6862 if (! isXpack) {
6963 if (job == ' serverMocha' ) {
70- return kibanaPipeline. getPostBuildWorker (' serverMocha' , {
64+ return kibanaPipeline. functionalTestProcess (' serverMocha' , {
7165 kibanaPipeline. bash(
7266 """
7367 source src/dev/ci_setup/setup_env.sh
@@ -77,20 +71,20 @@ def getWorkerFromParams(isXpack, job, ciGroup) {
7771 )
7872 })
7973 } else if (job == ' firefoxSmoke' ) {
80- return kibanaPipeline. getPostBuildWorker (' firefoxSmoke' , { runbld( ' ./test/scripts/jenkins_firefox_smoke.sh' , ' Execute kibana-firefoxSmoke ' ) } )
74+ return kibanaPipeline. functionalTestProcess (' firefoxSmoke' , ' ./test/scripts/jenkins_firefox_smoke.sh' )
8175 } else if (job == ' visualRegression' ) {
82- return kibanaPipeline. getPostBuildWorker (' visualRegression' , { runbld( ' ./test/scripts/jenkins_visual_regression.sh' , ' Execute kibana-visualRegression ' ) } )
76+ return kibanaPipeline. functionalTestProcess (' visualRegression' , ' ./test/scripts/jenkins_visual_regression.sh' )
8377 } else {
84- return kibanaPipeline. getOssCiGroupWorker (ciGroup)
78+ return kibanaPipeline. ossCiGroupProcess (ciGroup)
8579 }
8680 }
8781
8882 if (job == ' firefoxSmoke' ) {
89- return kibanaPipeline. getPostBuildWorker (' xpack-firefoxSmoke' , { runbld( ' ./test/scripts/jenkins_xpack_firefox_smoke.sh' , ' Execute xpack-firefoxSmoke ' ) } )
83+ return kibanaPipeline. functionalTestProcess (' xpack-firefoxSmoke' , ' ./test/scripts/jenkins_xpack_firefox_smoke.sh' )
9084 } else if (job == ' visualRegression' ) {
91- return kibanaPipeline. getPostBuildWorker (' xpack-visualRegression' , { runbld( ' ./test/scripts/jenkins_xpack_visual_regression.sh' , ' Execute xpack-visualRegression ' ) } )
85+ return kibanaPipeline. functionalTestProcess (' xpack-visualRegression' , ' ./test/scripts/jenkins_xpack_visual_regression.sh' )
9286 } else {
93- return kibanaPipeline. getXpackCiGroupWorker (ciGroup)
87+ return kibanaPipeline. xpackCiGroupProcess (ciGroup)
9488 }
9589}
9690
@@ -99,16 +93,15 @@ def getWorkerMap(agentNumber, numberOfExecutions, worker, workerFailures, maxWor
9993 def numberOfWorkers = Math . min(numberOfExecutions, maxWorkerProcesses)
10094
10195 for (def i = 1 ; i <= numberOfWorkers; i++ ) {
102- def workerExecutions = numberOfExecutions/ numberOfWorkers + (i <= numberOfExecutions% numberOfWorkers ? 1 : 0 )
96+ def workerExecutions = floor( numberOfExecutions/ numberOfWorkers + (i <= numberOfExecutions% numberOfWorkers ? 1 : 0 ) )
10397
10498 workerMap[" agent-${ agentNumber} -worker-${ i} " ] = { workerNumber ->
10599 for (def j = 0 ; j < workerExecutions; j++ ) {
106100 print " Execute agent-${ agentNumber} worker-${ workerNumber} : ${ j} "
107101 withEnv([
108- " JOB=agent-${ agentNumber} -worker-${ workerNumber} -${ j} " ,
109102 " REMOVE_KIBANA_INSTALL_DIR=1" ,
110103 ]) {
111- catchError {
104+ catchErrors {
112105 try {
113106 worker(workerNumber)
114107 } catch (ex) {
0 commit comments