From 8492be773e5f5bbf768586d7cf47314f6bb14101 Mon Sep 17 00:00:00 2001 From: kibanamachine <42973632+kibanamachine@users.noreply.github.com> Date: Wed, 21 Dec 2022 22:17:53 +0000 Subject: [PATCH] [CI] Auto-commit changed files from 'node scripts/eslint --no-cache --fix' --- .../server/task_runner/running_handler.ts | 35 +++++++++++-------- .../server/task_runner/task_runner.ts | 21 +++++++---- 2 files changed, 36 insertions(+), 20 deletions(-) diff --git a/x-pack/plugins/alerting/server/task_runner/running_handler.ts b/x-pack/plugins/alerting/server/task_runner/running_handler.ts index 42a1240a5b4c3b..c2e2e9bde61f8f 100644 --- a/x-pack/plugins/alerting/server/task_runner/running_handler.ts +++ b/x-pack/plugins/alerting/server/task_runner/running_handler.ts @@ -46,20 +46,27 @@ export class RunningHandler { private setRunning(ruleId: string, namespace?: string) { this.isUpdating = true; - this.runningPromise = partiallyUpdateAlert(this.client, ruleId, { running: true }, { - ignore404: true, - namespace: namespace, - refresh: false, - }); + this.runningPromise = partiallyUpdateAlert( + this.client, + ruleId, + { running: true }, + { + ignore404: true, + namespace, + refresh: false, + } + ); this.runningPromise - .then((mail) => { - this.runningPromise = undefined; - this.isUpdating = false - }) - .catch((err) => { - this.runningPromise = undefined; - this.isUpdating = false - this.logger.error(`error updating running attribute rule for ${this.ruleTypeId}:${ruleId} ${err.message}`); - }) + .then((mail) => { + this.runningPromise = undefined; + this.isUpdating = false; + }) + .catch((err) => { + this.runningPromise = undefined; + this.isUpdating = false; + this.logger.error( + `error updating running attribute rule for ${this.ruleTypeId}:${ruleId} ${err.message}` + ); + }); } } diff --git a/x-pack/plugins/alerting/server/task_runner/task_runner.ts b/x-pack/plugins/alerting/server/task_runner/task_runner.ts index 74a9102a1fc791..fa24dc841cf016 100644 --- a/x-pack/plugins/alerting/server/task_runner/task_runner.ts +++ b/x-pack/plugins/alerting/server/task_runner/task_runner.ts @@ -150,7 +150,11 @@ export class TaskRunner< this.alertingEventLogger = new AlertingEventLogger(this.context.eventLogger); this.stackTraceLog = null; this.ruleMonitoring = new RuleMonitoringService(); - this.ruleRunning = new RunningHandler(this.context.internalSavedObjectsRepository, this.logger, loggerId ) + this.ruleRunning = new RunningHandler( + this.context.internalSavedObjectsRepository, + this.logger, + loggerId + ); this.ruleResult = new RuleResultService(); } @@ -169,11 +173,16 @@ export class TaskRunner< await this.ruleRunning.waitFor(); } catch {} try { - await partiallyUpdateAlert(client, ruleId, {...attributes, running: false}, { - ignore404: true, - namespace, - refresh: false, - }); + await partiallyUpdateAlert( + client, + ruleId, + { ...attributes, running: false }, + { + ignore404: true, + namespace, + refresh: false, + } + ); } catch (err) { this.logger.error(`error updating rule for ${this.ruleType.id}:${ruleId} ${err.message}`); }