From 5b3b78bd3f409a4c867fce90afbe48f034c7b4ed Mon Sep 17 00:00:00 2001 From: Alex Holliday Date: Tue, 1 Oct 2024 12:36:37 +0800 Subject: [PATCH] Scale workers on deleting job --- Server/service/jobQueue.js | 4 +++- Server/service/settingsService.js | 2 +- 2 files changed, 4 insertions(+), 2 deletions(-) diff --git a/Server/service/jobQueue.js b/Server/service/jobQueue.js index 2652a4d53..58d628a2e 100644 --- a/Server/service/jobQueue.js +++ b/Server/service/jobQueue.js @@ -139,7 +139,7 @@ class JobQueue { return { jobs, load }; } catch (error) { error.service === undefined ? (error.service = SERVICE_NAME) : null; - errorObject.method === undefined + error.method === undefined ? (error.method = "getWorkerStats") : null; throw error; @@ -285,6 +285,8 @@ class JobQueue { service: SERVICE_NAME, jobId: monitor.id, }); + const workerStats = await this.getWorkerStats(); + await this.scaleWorkers(workerStats); } else { logger.error(errorMessages.JOB_QUEUE_DELETE_JOB, { service: SERVICE_NAME, diff --git a/Server/service/settingsService.js b/Server/service/settingsService.js index 1b86ab89f..24e890d64 100644 --- a/Server/service/settingsService.js +++ b/Server/service/settingsService.js @@ -1,5 +1,5 @@ const { env } = require("process"); -const AppSettings = require("../models/AppSettings"); +const AppSettings = require("../db/models/AppSettings"); const SERVICE_NAME = "SettingsService"; const envConfig = { logLevel: undefined,