feat: add interval for queue checks

2025-08-12 22:19:30 +05:30
parent b2f6211c22
commit fe4a12cfe4
1 changed files with 8 additions and 0 deletions
--- 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) {