From d2881927c18cddef767f043810532f887fd583a4 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Gerg=C5=91=20M=C3=B3ricz?= Date: Thu, 26 Sep 2024 20:29:17 +0200 Subject: [PATCH] fix(queue-worker): remove concurrency entries when done in sentry-less branch --- apps/api/src/services/queue-worker.ts | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/apps/api/src/services/queue-worker.ts b/apps/api/src/services/queue-worker.ts index 76796742..71bd6366 100644 --- a/apps/api/src/services/queue-worker.ts +++ b/apps/api/src/services/queue-worker.ts @@ -214,7 +214,9 @@ const workerFun = async ( () => { processJobInternal(token, job) .finally(() => { - + if (job.id && job.data && job.data.team_id) { + redisConnection.zrem(concurrencyLimiterKey, job.id); + } }); } );