github-mirrors/kibana
1
0
Fork 0
mirror of https://github.com/elastic/kibana.git synced 2025-04-24 09:48:58 -04:00
Code Issues Projects Releases Packages Wiki Activity

[esTestCluster] when stopping nodes, finish cleanup before throwing (#133252) (#133326)

Browse source 
(cherry picked from commit 07a865261e)

Co-authored-by: Spencer <spencer@elastic.co>
This commit is contained in:
Kibana Machine 2022-06-01 12:58:18 -05:00 • committed by GitHub
parent e36d9eb4b6
commit 66470b8b86
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
1 changed files with 18 additions and 3 deletions
Download patch file Download diff file Expand all files Collapse all files

21
packages/kbn-test/src/es/test_es_cluster.ts
View file

@ -283,7 +283,7 @@ export function createTestEsCluster<
}
async stop() {
await Promise.all(
const results = await Promise.allSettled(
this.nodes.map(async (node, i) => {
log.info(`[es] stopping node ${nodes[i].name}`);
await node.stop();
@ -291,8 +291,22 @@ export function createTestEsCluster<
);
log.info('[es] stopped');
await this.captureDebugFiles();
this.handleStopResults(results);
}
private handleStopResults(results: Array<PromiseSettledResult<void>>) {
const failures = results.flatMap((r) => (r.status === 'rejected' ? r : []));
if (failures.length === 1) {
throw failures[0].reason;
}
if (failures.length > 1) {
throw new Error(
`${failures.length} nodes failed:\n - ${failures
.map((f) => f.reason.message)
.join('\n - ')}`
);
}
}
async captureDebugFiles() {
@ -340,7 +354,7 @@ export function createTestEsCluster<
async cleanup() {
log.info('[es] killing', this.nodes.length === 1 ? 'node' : `${this.nodes.length} nodes`);
await Promise.all(
const results = await Promise.allSettled(
this.nodes.map(async (node, i) => {
log.info(`[es] stopping node ${nodes[i].name}`);
// we are deleting this install, stop ES more aggressively
@ -351,6 +365,7 @@ export function createTestEsCluster<
await this.captureDebugFiles();
await del(config.installPath, { force: true });
log.info('[es] cleanup complete');
this.handleStopResults(results);
}
/**