From 3d579f7002b7a030f2f0bc5a7ff22198acc68788 Mon Sep 17 00:00:00 2001 From: Jari Kolehmainen Date: Wed, 18 Aug 2021 11:14:19 +0300 Subject: [PATCH] make linter happy Signed-off-by: Jari Kolehmainen --- src/common/k8s-api/kube-api.ts | 8 +++++--- 1 file changed, 5 insertions(+), 3 deletions(-) diff --git a/src/common/k8s-api/kube-api.ts b/src/common/k8s-api/kube-api.ts index 6a2a46abd2..33ed422601 100644 --- a/src/common/k8s-api/kube-api.ts +++ b/src/common/k8s-api/kube-api.ts @@ -425,7 +425,7 @@ export class KubeApi { let errorReceived = false; let timedRetry: NodeJS.Timeout; const { abortController: { abort, signal } = new AbortController(), namespace, callback = noop, retry } = opts; - let { watchId = `${this.kind.toLowerCase()}-${this.watchId++}` } = opts; + const { watchId = `${this.kind.toLowerCase()}-${this.watchId++}` } = opts; signal.addEventListener("abort", () => { logger.info(`[KUBE-API] watch (${watchId}) aborted ${watchUrl}`); @@ -434,12 +434,14 @@ export class KubeApi { const watchUrl = this.getWatchUrl(namespace); const responsePromise = this.request.getResponse(watchUrl, null, { signal, timeout: 600_000 }); - logger.info(`[KUBE-API] watch (${watchId}) ${ retry === true ? "retried" : "started" } ${watchUrl}`); + + logger.info(`[KUBE-API] watch (${watchId}) ${retry === true ? "retried" : "started"} ${watchUrl}`); responsePromise .then(response => { if (!response.ok) { - logger.warn(`[KUBE-API] watch (${watchId}) error response ${watchUrl}`, { status: response.status }) + logger.warn(`[KUBE-API] watch (${watchId}) error response ${watchUrl}`, { status: response.status }); + return callback(null, response); }