diff --git a/packages/das/src/queue/fetch.processor.ts b/packages/das/src/queue/fetch.processor.ts index 08e1e6d..7b59314 100644 --- a/packages/das/src/queue/fetch.processor.ts +++ b/packages/das/src/queue/fetch.processor.ts @@ -245,7 +245,9 @@ export class FetchProcessor extends WorkerHost { expectedBaseSha, ), removeOnComplete: true, - removeOnFail: 50, + // Match PR_METADATA (#75/#118) — failed files jobs must not squat + // on the stable per-SHA jobId (#124). + removeOnFail: true, attempts: 3, backoff: { type: "exponential", delay: 5000 }, }, diff --git a/packages/das/src/webhook/handlers/pull-request.handler.ts b/packages/das/src/webhook/handlers/pull-request.handler.ts index 53dbee8..85f54c9 100644 --- a/packages/das/src/webhook/handlers/pull-request.handler.ts +++ b/packages/das/src/webhook/handlers/pull-request.handler.ts @@ -118,7 +118,9 @@ export class PullRequestHandler { { jobId, removeOnComplete: true, - removeOnFail: 50, + // Match PR_METADATA (#75/#118) — failed files jobs must not squat + // on the stable per-SHA jobId (#124). + removeOnFail: true, attempts: 3, backoff: { type: "exponential", delay: 5000 }, },