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) {