From 4f27d2128b76c39c66d65d86f49fcc0b48629e19 Mon Sep 17 00:00:00 2001
From: Harshith Mullapudi <harshithmullapudi@gmail.com>
Date: Thu, 30 Oct 2025 12:29:39 +0530
Subject: [PATCH] fix: worker logging

---
 apps/webapp/app/bullmq/start-workers.ts | 34 +++++++++++++++++++++++++
 1 file changed, 34 insertions(+)

diff --git a/apps/webapp/app/bullmq/start-workers.ts b/apps/webapp/app/bullmq/start-workers.ts
index b16c597..943024b 100644
--- a/apps/webapp/app/bullmq/start-workers.ts
+++ b/apps/webapp/app/bullmq/start-workers.ts
@@ -15,12 +15,18 @@ import {
   conversationTitleWorker,
   sessionCompactionWorker,
   closeAllWorkers,
+  bertTopicWorker,
+  spaceAssignmentWorker,
+  spaceSummaryWorker,
 } from "./workers";
 import {
   ingestQueue,
   documentIngestQueue,
   conversationTitleQueue,
   sessionCompactionQueue,
+  bertTopicQueue,
+  spaceAssignmentQueue,
+  spaceSummaryQueue,
 } from "./queues";
 import {
   setupWorkerLogging,
@@ -52,6 +58,16 @@ export async function initWorkers(): Promise<void> {
     "session-compaction",
   );
 
+  setupWorkerLogging(bertTopicWorker, bertTopicQueue, "bert-topic");
+
+  setupWorkerLogging(
+    spaceAssignmentWorker,
+    spaceAssignmentQueue,
+    "space-assignment",
+  );
+
+  setupWorkerLogging(spaceSummaryWorker, spaceSummaryQueue, "space-summary");
+
   // Start periodic metrics logging (every 60 seconds)
   metricsInterval = startPeriodicMetricsLogging(
     [
@@ -71,6 +87,24 @@ export async function initWorkers(): Promise<void> {
         queue: sessionCompactionQueue,
         name: "session-compaction",
       },
+
+      {
+        worker: bertTopicWorker,
+        queue: bertTopicQueue,
+        name: "bert-topic",
+      },
+
+      {
+        worker: spaceAssignmentWorker,
+        queue: spaceAssignmentQueue,
+        name: "space-assignment",
+      },
+
+      {
+        worker: spaceSummaryWorker,
+        queue: spaceAssignmentQueue,
+        name: "space-summary",
+      },
     ],
     60000, // Log metrics every 60 seconds
   );