Skip to content

Commit fe4a12c

Browse files
committed
feat: add interval for queue checks
1 parent b2f6211 commit fe4a12c

File tree

1 file changed

+8
-0
lines changed

1 file changed

+8
-0
lines changed

server/src/pgboss-worker.ts

Lines changed: 8 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -797,6 +797,10 @@ async function registerRunExecutionWorker() {
797797
};
798798

799799
await checkForNewUserQueues();
800+
801+
setInterval(async () => {
802+
await checkForNewUserQueues();
803+
}, 10000);
800804

801805
logger.log('info', 'Run execution worker registered successfully');
802806
} catch (error: unknown) {
@@ -843,6 +847,10 @@ async function registerAbortRunWorker() {
843847
};
844848

845849
await checkForNewAbortQueues();
850+
851+
setInterval(async () => {
852+
await checkForNewAbortQueues();
853+
}, 10000);
846854

847855
logger.log('info', 'Abort run worker registration system initialized');
848856
} catch (error: unknown) {

0 commit comments

Comments
 (0)