From d686a8de5e2920193a36e36f7dad87fe789366eb Mon Sep 17 00:00:00 2001
From: Alex Holliday <ajhollid@gmail.com>
Date: Fri, 27 Dec 2024 14:00:47 -0800
Subject: [PATCH] made adding jobs and scaling workers non-blocking

---
 Server/service/jobQueue.js | 25 ++++++++++++++++++++++---
 1 file changed, 22 insertions(+), 3 deletions(-)

diff --git a/Server/service/jobQueue.js b/Server/service/jobQueue.js
index cfe1b2ccf..bf7e11479 100644
--- a/Server/service/jobQueue.js
+++ b/Server/service/jobQueue.js
@@ -90,11 +90,30 @@ class JobQueue {
 			const monitors = await db.getAllMonitors();
 			for (const monitor of monitors) {
 				if (monitor.isActive) {
-					await queue.addJob(monitor.id, monitor);
+					queue.addJob(monitor.id, monitor).catch((error) => {
+						this.logger.error({
+							message: error.message,
+							service: SERVICE_NAME,
+							method: "createJobQueue",
+							stack: error.stack,
+						});
+					});
 				}
 			}
-			const workerStats = await queue.getWorkerStats();
-			await queue.scaleWorkers(workerStats);
+
+			queue
+				.getWorkerStats()
+				.then((workerStats) => {
+					queue.scaleWorkers(workerStats);
+				})
+				.catch((error) => {
+					this.logger.error({
+						message: error.message,
+						service: SERVICE_NAME,
+						method: "createJobQueue",
+						stack: error.stack,
+					});
+				});
 			return queue;
 		} catch (error) {
 			error.service === undefined ? (error.service = SERVICE_NAME) : null;