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); + } }); } );