fix(queue-worker): remove concurrency entries when done in sentry-less branch
This commit is contained in:
@@ -214,7 +214,9 @@ const workerFun = async (
|
|||||||
() => {
|
() => {
|
||||||
processJobInternal(token, job)
|
processJobInternal(token, job)
|
||||||
.finally(() => {
|
.finally(() => {
|
||||||
|
if (job.id && job.data && job.data.team_id) {
|
||||||
|
redisConnection.zrem(concurrencyLimiterKey, job.id);
|
||||||
|
}
|
||||||
});
|
});
|
||||||
}
|
}
|
||||||
);
|
);
|
||||||
|
|||||||
Reference in New Issue
Block a user