Fix BullMQ job dedup — remove completed/failed jobs
Publish Image / publish (push) Successful in 21s
Publish Image / publish (push) Successful in 21s
Completed jobs with the same jobId block new jobs from being added. Add removeOnComplete and removeOnFail to all job options so the same task can be re-triggered after completion. Co-Authored-By: Claude Opus 4.6 <noreply@anthropic.com>
This commit is contained in:
co-authored by
Claude Opus 4.6
parent
2cdf68ddff
commit
a72ea9ad1d
@@ -161,6 +161,8 @@ export class TaskQueue {
|
||||
jobId: `create-${key}`,
|
||||
attempts: 3,
|
||||
backoff: { type: "exponential", delay: 5000 },
|
||||
removeOnComplete: true,
|
||||
removeOnFail: true,
|
||||
},
|
||||
);
|
||||
} catch (err: unknown) {
|
||||
@@ -201,6 +203,8 @@ export class TaskQueue {
|
||||
jobId: `cleanup-${workspaceName}`,
|
||||
attempts: 5,
|
||||
backoff: { type: "exponential", delay: 10000 },
|
||||
removeOnComplete: true,
|
||||
removeOnFail: true,
|
||||
},
|
||||
);
|
||||
|
||||
@@ -311,6 +315,8 @@ export class TaskQueue {
|
||||
jobId: `cleanup-stale-${ws.name}-${Date.now()}`,
|
||||
attempts: 5,
|
||||
backoff: { type: "exponential", delay: 10000 },
|
||||
removeOnComplete: true,
|
||||
removeOnFail: true,
|
||||
},
|
||||
);
|
||||
} catch (err) {
|
||||
|
||||
Reference in New Issue
Block a user