-
Notifications
You must be signed in to change notification settings - Fork 8.3k
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
- Loading branch information
Showing
10,116 changed files
with
371,504 additions
and
284,328 deletions.
The diff you're trying to view is too large. We only load the first 3000 changed files.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Original file line number | Diff line number | Diff line change |
---|---|---|
@@ -0,0 +1,146 @@ | ||
#!/bin/groovy | ||
|
||
library 'kibana-pipeline-library' | ||
kibanaLibrary.load() | ||
|
||
def CI_GROUP_PARAM = params.CI_GROUP | ||
|
||
// Looks like 'oss:ciGroup:1', 'oss:firefoxSmoke', or 'all:serverMocha' | ||
def JOB_PARTS = CI_GROUP_PARAM.split(':') | ||
def IS_XPACK = JOB_PARTS[0] == 'xpack' | ||
def JOB = JOB_PARTS[1] | ||
def NEED_BUILD = JOB != 'serverMocha' | ||
def CI_GROUP = JOB_PARTS.size() > 2 ? JOB_PARTS[2] : '' | ||
def EXECUTIONS = params.NUMBER_EXECUTIONS.toInteger() | ||
def AGENT_COUNT = getAgentCount(EXECUTIONS) | ||
|
||
def worker = getWorkerFromParams(IS_XPACK, JOB, CI_GROUP) | ||
|
||
def workerFailures = [] | ||
|
||
currentBuild.displayName += trunc(" ${params.GITHUB_OWNER}:${params.branch_specifier}", 24) | ||
currentBuild.description = "${params.CI_GROUP}<br />Agents: ${AGENT_COUNT}<br />Executions: ${params.NUMBER_EXECUTIONS}" | ||
|
||
stage("Kibana Pipeline") { | ||
timeout(time: 180, unit: 'MINUTES') { | ||
timestamps { | ||
ansiColor('xterm') { | ||
def agents = [:] | ||
for(def agentNumber = 1; agentNumber <= AGENT_COUNT; agentNumber++) { | ||
def agentNumberInside = agentNumber | ||
def agentExecutions = floor(EXECUTIONS/AGENT_COUNT) + (agentNumber <= EXECUTIONS%AGENT_COUNT ? 1 : 0) | ||
agents["agent-${agentNumber}"] = { | ||
catchError { | ||
print "Agent ${agentNumberInside} - ${agentExecutions} executions" | ||
|
||
kibanaPipeline.withWorkers('flaky-test-runner', { | ||
if (NEED_BUILD) { | ||
if (!IS_XPACK) { | ||
kibanaPipeline.buildOss() | ||
if (CI_GROUP == '1') { | ||
runbld("./test/scripts/jenkins_build_kbn_tp_sample_panel_action.sh", "Build kbn tp sample panel action for ciGroup1") | ||
} | ||
} else { | ||
kibanaPipeline.buildXpack() | ||
} | ||
} | ||
}, getWorkerMap(agentNumberInside, agentExecutions, worker, workerFailures))() | ||
} | ||
} | ||
} | ||
|
||
parallel(agents) | ||
|
||
currentBuild.description += ", Failures: ${workerFailures.size()}" | ||
|
||
if (workerFailures.size() > 0) { | ||
print "There were ${workerFailures.size()} test suite failures." | ||
print "The executions that failed were:" | ||
print workerFailures.join("\n") | ||
print "Please check 'Test Result' and 'Pipeline Steps' pages for more info" | ||
} | ||
} | ||
} | ||
} | ||
} | ||
|
||
def getWorkerFromParams(isXpack, job, ciGroup) { | ||
if (!isXpack) { | ||
if (job == 'serverMocha') { | ||
return kibanaPipeline.getPostBuildWorker('serverMocha', { | ||
kibanaPipeline.bash( | ||
""" | ||
source src/dev/ci_setup/setup_env.sh | ||
node scripts/mocha | ||
""", | ||
"run `node scripts/mocha`" | ||
) | ||
}) | ||
} else if (job == 'firefoxSmoke') { | ||
return kibanaPipeline.getPostBuildWorker('firefoxSmoke', { runbld('./test/scripts/jenkins_firefox_smoke.sh', 'Execute kibana-firefoxSmoke') }) | ||
} else if(job == 'visualRegression') { | ||
return kibanaPipeline.getPostBuildWorker('visualRegression', { runbld('./test/scripts/jenkins_visual_regression.sh', 'Execute kibana-visualRegression') }) | ||
} else { | ||
return kibanaPipeline.getOssCiGroupWorker(ciGroup) | ||
} | ||
} | ||
|
||
if (job == 'firefoxSmoke') { | ||
return kibanaPipeline.getPostBuildWorker('xpack-firefoxSmoke', { runbld('./test/scripts/jenkins_xpack_firefox_smoke.sh', 'Execute xpack-firefoxSmoke') }) | ||
} else if(job == 'visualRegression') { | ||
return kibanaPipeline.getPostBuildWorker('xpack-visualRegression', { runbld('./test/scripts/jenkins_xpack_visual_regression.sh', 'Execute xpack-visualRegression') }) | ||
} else { | ||
return kibanaPipeline.getXpackCiGroupWorker(ciGroup) | ||
} | ||
} | ||
|
||
def getWorkerMap(agentNumber, numberOfExecutions, worker, workerFailures, maxWorkerProcesses = 12) { | ||
def workerMap = [:] | ||
def numberOfWorkers = Math.min(numberOfExecutions, maxWorkerProcesses) | ||
|
||
for(def i = 1; i <= numberOfWorkers; i++) { | ||
def workerExecutions = numberOfExecutions/numberOfWorkers + (i <= numberOfExecutions%numberOfWorkers ? 1 : 0) | ||
|
||
workerMap["agent-${agentNumber}-worker-${i}"] = { workerNumber -> | ||
for(def j = 0; j < workerExecutions; j++) { | ||
print "Execute agent-${agentNumber} worker-${workerNumber}: ${j}" | ||
withEnv([ | ||
"JOB=agent-${agentNumber}-worker-${workerNumber}-${j}", | ||
"REMOVE_KIBANA_INSTALL_DIR=1", | ||
]) { | ||
catchError { | ||
try { | ||
worker(workerNumber) | ||
} catch (ex) { | ||
workerFailures << "agent-${agentNumber} worker-${workerNumber}-${j}" | ||
throw ex | ||
} | ||
} | ||
} | ||
} | ||
} | ||
} | ||
|
||
return workerMap | ||
} | ||
|
||
def getAgentCount(executions) { | ||
// Increase agent count every 24 worker processess, up to 3 agents maximum | ||
return Math.min(3, 1 + floor(executions/24)) | ||
} | ||
|
||
def trunc(str, length) { | ||
if (str.size() >= length) { | ||
return str.take(length) + "..." | ||
} | ||
|
||
return str; | ||
} | ||
|
||
// All of the real rounding/truncating methods are sandboxed | ||
def floor(num) { | ||
return num | ||
.toString() | ||
.split('\\.')[0] | ||
.toInteger() | ||
} |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Original file line number | Diff line number | Diff line change |
---|---|---|
@@ -0,0 +1,125 @@ | ||
#!/usr/bin/env groovy | ||
|
||
library identifier: 'apm@current', | ||
retriever: modernSCM( | ||
[$class: 'GitSCMSource', | ||
credentialsId: 'f94e9298-83ae-417e-ba91-85c279771570', | ||
id: '37cf2c00-2cc7-482e-8c62-7bbffef475e2', | ||
remote: 'git@github.com:elastic/apm-pipeline-library.git']) | ||
|
||
pipeline { | ||
agent { label 'linux && immutable' } | ||
environment { | ||
BASE_DIR = 'src/github.com/elastic/kibana' | ||
HOME = "${env.WORKSPACE}" | ||
APM_ITS = 'apm-integration-testing' | ||
CYPRESS_DIR = 'x-pack/legacy/plugins/apm/cypress' | ||
PIPELINE_LOG_LEVEL = 'DEBUG' | ||
} | ||
options { | ||
timeout(time: 1, unit: 'HOURS') | ||
buildDiscarder(logRotator(numToKeepStr: '40', artifactNumToKeepStr: '20', daysToKeepStr: '30')) | ||
timestamps() | ||
ansiColor('xterm') | ||
disableResume() | ||
durabilityHint('PERFORMANCE_OPTIMIZED') | ||
} | ||
triggers { | ||
issueCommentTrigger('(?i).*jenkins\\W+run\\W+(?:the\\W+)?e2e(?:\\W+please)?.*') | ||
} | ||
parameters { | ||
booleanParam(name: 'FORCE', defaultValue: false, description: 'Whether to force the run.') | ||
} | ||
stages { | ||
stage('Checkout') { | ||
options { skipDefaultCheckout() } | ||
steps { | ||
deleteDir() | ||
gitCheckout(basedir: "${BASE_DIR}", githubNotifyFirstTimeContributor: false, | ||
shallow: false, reference: "/var/lib/jenkins/.git-references/kibana.git") | ||
script { | ||
dir("${BASE_DIR}"){ | ||
def regexps =[ "^x-pack/legacy/plugins/apm/.*" ] | ||
env.APM_UPDATED = isGitRegionMatch(patterns: regexps) | ||
} | ||
} | ||
dir("${APM_ITS}"){ | ||
git changelog: false, | ||
credentialsId: 'f6c7695a-671e-4f4f-a331-acdce44ff9ba', | ||
poll: false, | ||
url: "git@github.com:elastic/${APM_ITS}.git" | ||
} | ||
} | ||
} | ||
stage('Start services') { | ||
options { skipDefaultCheckout() } | ||
when { | ||
anyOf { | ||
expression { return params.FORCE } | ||
expression { return env.APM_UPDATED != "false" } | ||
} | ||
} | ||
steps { | ||
dir("${APM_ITS}"){ | ||
sh './scripts/compose.py start master --no-kibana --no-xpack-secure' | ||
} | ||
} | ||
} | ||
stage('Prepare Kibana') { | ||
options { skipDefaultCheckout() } | ||
when { | ||
anyOf { | ||
expression { return params.FORCE } | ||
expression { return env.APM_UPDATED != "false" } | ||
} | ||
} | ||
environment { | ||
JENKINS_NODE_COOKIE = 'dontKillMe' | ||
} | ||
steps { | ||
dir("${BASE_DIR}"){ | ||
sh script: "${CYPRESS_DIR}/ci/prepare-kibana.sh" | ||
} | ||
} | ||
} | ||
stage('Smoke Tests'){ | ||
options { skipDefaultCheckout() } | ||
when { | ||
anyOf { | ||
expression { return params.FORCE } | ||
expression { return env.APM_UPDATED != "false" } | ||
} | ||
} | ||
steps{ | ||
dir("${BASE_DIR}"){ | ||
sh ''' | ||
jobs -l | ||
docker build --tag cypress ${CYPRESS_DIR}/ci | ||
docker run --rm -t --user "$(id -u):$(id -g)" \ | ||
-v `pwd`:/app --network="host" \ | ||
--name cypress cypress''' | ||
} | ||
} | ||
post { | ||
always { | ||
dir("${BASE_DIR}"){ | ||
archiveArtifacts(allowEmptyArchive: false, artifacts: "${CYPRESS_DIR}/screenshots/**,${CYPRESS_DIR}/videos/**,${CYPRESS_DIR}/*e2e-tests.xml") | ||
junit(allowEmptyResults: true, testResults: "${CYPRESS_DIR}/*e2e-tests.xml") | ||
} | ||
dir("${APM_ITS}"){ | ||
sh 'docker-compose logs > apm-its.log || true' | ||
sh 'docker-compose down -v || true' | ||
archiveArtifacts(allowEmptyArchive: false, artifacts: 'apm-its.log') | ||
} | ||
} | ||
} | ||
} | ||
} | ||
post { | ||
always { | ||
dir("${BASE_DIR}"){ | ||
archiveArtifacts(allowEmptyArchive: true, artifacts: "${CYPRESS_DIR}/ingest-data.log,kibana.log") | ||
} | ||
} | ||
} | ||
} |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Oops, something went wrong.