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,