Skip to content

Commit aae6084

Browse files
elasticmachineelasticmachine
authored
Merge branch 'master' into testbed/move-to-oss
2 parents 6fd1331 + 66a0e67 commit aae6084

1 file changed

Lines changed: 15 additions & 15 deletions

File tree

‎packages/kbn-pm/dist/index.js‎

Lines changed: 15 additions & 15 deletions
Original file line numberDiff line numberDiff line change
@@ -4859,7 +4859,7 @@ class ProcRunner {
48594859
this.closing = false;
48604860
this.procs = [];
48614861
this.signalUnsubscribe = exit_hook_1.default(() => {
4862-
this.teardown().catch(error => {
4862+
this.teardown().catch((error) => {
48634863
log.error(`ProcRunner teardown error: ${error.stack}`);
48644864
});
48654865
});
@@ -4898,7 +4898,7 @@ class ProcRunner {
48984898
try {
48994899
if (wait instanceof RegExp) {
49004900
// wait for process to log matching line
4901-
await Rx.race(proc.lines$.pipe(operators_1.filter(line => wait.test(line)), operators_1.first(), operators_1.catchError(err => {
4901+
await Rx.race(proc.lines$.pipe(operators_1.filter((line) => wait.test(line)), operators_1.first(), operators_1.catchError((err) => {
49024902
if (err.name !== 'EmptyError') {
49034903
throw errors_1.createCliError(`[${name}] exited without matching pattern: ${wait}`);
49044904
}
@@ -4943,7 +4943,7 @@ class ProcRunner {
49434943
* @return {Promise<undefined>}
49444944
*/
49454945
async waitForAllToStop() {
4946-
await Promise.all(this.procs.map(proc => proc.outcomePromise));
4946+
await Promise.all(this.procs.map((proc) => proc.outcomePromise));
49474947
}
49484948
/**
49494949
* Close the ProcRunner and stop all running
@@ -4959,14 +4959,14 @@ class ProcRunner {
49594959
this.closing = true;
49604960
this.signalUnsubscribe();
49614961
if (!signal && this.procs.length > 0) {
4962-
this.log.warning('%d processes left running, stop them with procs.stop(name):', this.procs.length, this.procs.map(proc => proc.name));
4962+
this.log.warning('%d processes left running, stop them with procs.stop(name):', this.procs.length, this.procs.map((proc) => proc.name));
49634963
}
49644964
await Promise.all(this.procs.map(async (proc) => {
49654965
await proc.stop(signal === 'exit' ? 'SIGKILL' : signal);
49664966
}));
49674967
}
49684968
getProc(name) {
4969-
return this.procs.find(proc => {
4969+
return this.procs.find((proc) => {
49704970
return proc.name === name;
49714971
});
49724972
}
@@ -4979,14 +4979,14 @@ class ProcRunner {
49794979
};
49804980
// tie into proc outcome$, remove from _procs on compete
49814981
proc.outcome$.subscribe({
4982-
next: code => {
4982+
next: (code) => {
49834983
const duration = moment_1.default.duration(Date.now() - startMs);
49844984
this.log.info('[%s] exited with %s after %s', name, code, duration.humanize());
49854985
},
49864986
complete: () => {
49874987
remove();
49884988
},
4989-
error: error => {
4989+
error: (error) => {
49904990
if (this.closing) {
49914991
this.log.error(error);
49924992
}
@@ -33599,8 +33599,8 @@ function startProc(name, options, log) {
3359933599
return code;
3360033600
})),
3360133601
// observe first error event
33602-
Rx.fromEvent(childProcess, 'error').pipe(operators_1.take(1), operators_1.mergeMap(err => Rx.throwError(err)))).pipe(operators_1.share());
33603-
const lines$ = Rx.merge(observe_lines_1.observeLines(childProcess.stdout), observe_lines_1.observeLines(childProcess.stderr)).pipe(operators_1.tap(line => log.write(` ${chalk_1.default.gray('proc')} [${chalk_1.default.gray(name)}] ${line}`)), operators_1.share());
33602+
Rx.fromEvent(childProcess, 'error').pipe(operators_1.take(1), operators_1.mergeMap((err) => Rx.throwError(err)))).pipe(operators_1.share());
33603+
const lines$ = Rx.merge(observe_lines_1.observeLines(childProcess.stdout), observe_lines_1.observeLines(childProcess.stderr)).pipe(operators_1.tap((line) => log.write(` ${chalk_1.default.gray('proc')} [${chalk_1.default.gray(name)}] ${line}`)), operators_1.share());
3360433604
const outcomePromise = Rx.merge(lines$.pipe(operators_1.ignoreElements()), outcome$).toPromise();
3360533605
async function stop(signal) {
3360633606
if (stopCalled) {
@@ -36584,7 +36584,7 @@ const operators_1 = __webpack_require__(270);
3658436584
* - fails on the first "error" event
3658536585
*/
3658636586
function observeReadable(readable) {
36587-
return Rx.race(Rx.fromEvent(readable, 'end').pipe(operators_1.first(), operators_1.ignoreElements()), Rx.fromEvent(readable, 'error').pipe(operators_1.first(), operators_1.mergeMap(err => Rx.throwError(err))));
36587+
return Rx.race(Rx.fromEvent(readable, 'end').pipe(operators_1.first(), operators_1.ignoreElements()), Rx.fromEvent(readable, 'error').pipe(operators_1.first(), operators_1.mergeMap((err) => Rx.throwError(err))));
3658836588
}
3658936589
exports.observeReadable = observeReadable;
3659036590

@@ -36894,7 +36894,7 @@ class ToolingLogCollectingWriter extends tooling_log_text_writer_1.ToolingLogTex
3689436894
super({
3689536895
level: 'verbose',
3689636896
writeTo: {
36897-
write: msg => {
36897+
write: (msg) => {
3689836898
// trim trailing new line
3689936899
this.messages.push(msg.slice(0, -1));
3690036900
},
@@ -39475,7 +39475,7 @@ async function run(fn, options = {}) {
3947539475
level: tooling_log_1.pickLevelFromFlags(flags),
3947639476
writeTo: process.stdout,
3947739477
});
39478-
process.on('unhandledRejection', error => {
39478+
process.on('unhandledRejection', (error) => {
3947939479
log.error('UNHANDLED PROMISE REJECTION');
3948039480
log.error(error instanceof Error
3948139481
? error
@@ -39589,7 +39589,7 @@ function combineErrors(errors) {
3958939589
const exitCode = errors
3959039590
.filter(isFailError)
3959139591
.reduce((acc, error) => Math.max(acc, error.exitCode), 1);
39592-
const showHelp = errors.some(error => isFailError(error) && error.showHelp);
39592+
const showHelp = errors.some((error) => isFailError(error) && error.showHelp);
3959339593
const message = errors.reduce((acc, error) => {
3959439594
if (isFailError(error)) {
3959539595
return acc + '\n' + error.message;
@@ -40091,7 +40091,7 @@ exports.uriencode = (strings, ...values) => {
4009140091
return queue.reduce((acc, string, i) => `${acc}${encodeURIComponent(values[i])}${string}`, leadingString);
4009240092
};
4009340093
const DEFAULT_MAX_ATTEMPTS = 5;
40094-
const delay = (ms) => new Promise(resolve => {
40094+
const delay = (ms) => new Promise((resolve) => {
4009540095
setTimeout(resolve, ms);
4009640096
});
4009740097
class KbnClientRequester {
@@ -43984,7 +43984,7 @@ class CiStatsReporter {
4398443984
const reason = ((_d = (_c = error) === null || _c === void 0 ? void 0 : _c.response) === null || _d === void 0 ? void 0 : _d.status) ? `${error.response.status} response`
4398543985
: 'no response';
4398643986
this.log.warning(`failed to reach kibana-ci-stats service [reason=${reason}], retrying in ${attempt} seconds`);
43987-
await new Promise(resolve => setTimeout(resolve, attempt * 1000));
43987+
await new Promise((resolve) => setTimeout(resolve, attempt * 1000));
4398843988
}
4398943989
}
4399043990
}

0 commit comments

Comments
 (0)