fix(queue): catch exceptions in scheduled runs

fork-house · Dec 23, 2024 · bdf5a71 · bdf5a71
1 parent 76ff593
commit bdf5a71
Showing 1 changed file with 6 additions and 2 deletions.
diff --git a/packages/backend/src/modules/queue/queue.entity.ts b/packages/backend/src/modules/queue/queue.entity.ts
@@ -55,8 +55,12 @@ export class Queue<T extends ZodSchema, R extends ZodSchema<{ success: boolean;
       throw new Error('Invalid event data');
     }
 
-    cron.schedule(cronPattern, () => {
-      this.rpcClient.send(this.queueName, eventData.data);
+    cron.schedule(cronPattern, async () => {
+      try {
+        await this.rpcClient.send(this.queueName, eventData.data);
+      } catch (e) {
+        console.error('Error in cron job:', e);
+      }
     });
   }
 }