From 299ae95a0d9841cf3254aa79db21fa22e7036171 Mon Sep 17 00:00:00 2001
From: Alex Holliday <ajhollid@gmail.com>
Date: Mon, 6 Jan 2025 14:30:48 -0800
Subject: [PATCH] Add more logging to jobqueue

---
 Server/service/jobQueue.js | 28 +++++++++++++++++++++++++++-
 1 file changed, 27 insertions(+), 1 deletion(-)

diff --git a/Server/service/jobQueue.js b/Server/service/jobQueue.js
index 9b5663350..fb5c306b1 100644
--- a/Server/service/jobQueue.js
+++ b/Server/service/jobQueue.js
@@ -217,6 +217,23 @@ class NewJobQueue {
 			connection: this.connection,
 			concurrency: 5,
 		});
+
+		worker.on("active", (job) => {
+			this.logger.info({
+				message: `Worker started processing job: ${job.id}`,
+				service: SERVICE_NAME,
+				method: "createWorker",
+			});
+		});
+
+		worker.on("completed", (job) => {
+			this.logger.info({
+				message: `Worker completed job: ${job.id}`,
+				service: SERVICE_NAME,
+				method: "createWorker",
+			});
+		});
+
 		worker.on("failed", (job, err) => {
 			this.logger.error({
 				message: `Worker failed job: ${job.id}`,
@@ -225,6 +242,14 @@ class NewJobQueue {
 				stack: err.stack,
 			});
 		});
+
+		worker.on("stalled", (jobId) => {
+			this.logger.warn({
+				message: `Worker stalled job: ${jobId}`,
+				service: SERVICE_NAME,
+				method: "createWorker",
+			});
+		});
 		return worker;
 	}
 
@@ -353,8 +378,9 @@ class NewJobQueue {
 					const jobs = await queue.getJobs();
 					const ret = await Promise.all(
 						jobs.map(async (job) => {
+							console.log(job);
 							const state = await job.getState();
-							return { url: job.data.url, state };
+							return { url: job.data.url, state, progress: job.progress };
 						})
 					);
 					stats[name] = { jobs: ret, workers: this.workers[name].length };