From fe4a12cfe48bdcbc65cb1a965a58d68850681c4e Mon Sep 17 00:00:00 2001
From: Rohit <rohit.rajan031101@gmail.com>
Date: Tue, 12 Aug 2025 22:19:30 +0530
Subject: [PATCH] feat: add interval for queue checks

---
 server/src/pgboss-worker.ts | 8 ++++++++
 1 file changed, 8 insertions(+)

diff --git a/server/src/pgboss-worker.ts b/server/src/pgboss-worker.ts
index 5f3bc692..c8baa9c0 100644
--- a/server/src/pgboss-worker.ts
+++ b/server/src/pgboss-worker.ts
@@ -797,6 +797,10 @@ async function registerRunExecutionWorker() {
     };
 
     await checkForNewUserQueues();
+
+    setInterval(async () => {
+      await checkForNewUserQueues();
+    }, 10000);
     
     logger.log('info', 'Run execution worker registered successfully');
   } catch (error: unknown) {
@@ -843,6 +847,10 @@ async function registerAbortRunWorker() {
     };
 
     await checkForNewAbortQueues();
+
+    setInterval(async () => {
+      await checkForNewAbortQueues();
+    }, 10000);
     
     logger.log('info', 'Abort run worker registration system initialized');
   } catch (error: unknown) {