From 5657abb21ea1438ad9c0190cfecdbf45d236c4aa Mon Sep 17 00:00:00 2001 From: Rohit Date: Wed, 12 Mar 2025 23:08:51 +0530 Subject: [PATCH] feat: user specific queue for run --- server/src/routes/storage.ts | 6 ++++-- 1 file changed, 4 insertions(+), 2 deletions(-) diff --git a/server/src/routes/storage.ts b/server/src/routes/storage.ts index ffdf0149..357c199f 100644 --- a/server/src/routes/storage.ts +++ b/server/src/routes/storage.ts @@ -658,10 +658,12 @@ router.post('/runs/run/:id', requireSignIn, async (req: AuthenticatedRequest, re } try { + const userQueueName = `execute-run-user-${req.user.id}`; + // Queue the execution job - await pgBoss.createQueue('execute-run'); + await pgBoss.createQueue(userQueueName); - const jobId = await pgBoss.send('execute-run', { + const jobId = await pgBoss.send(userQueueName, { userId: req.user.id, runId: req.params.id, browserId: plainRun.browserId