diff --git a/packages/content-fetch/src/job.ts b/packages/content-fetch/src/job.ts index ba70478af1..dcdfc2e525 100644 --- a/packages/content-fetch/src/job.ts +++ b/packages/content-fetch/src/job.ts @@ -38,7 +38,7 @@ const getAttempts = (job: savePageJob): number => { return 1 } - return 2 + return 3 } const getOpts = (job: savePageJob): BulkJobOptions => { @@ -48,6 +48,10 @@ const getOpts = (job: savePageJob): BulkJobOptions => { // removeOnFail: true, attempts: getAttempts(job), priority: getPriority(job), + backoff: { + type: 'exponential', + delay: 2000, + }, } } diff --git a/packages/pdf-handler/src/job.ts b/packages/pdf-handler/src/job.ts index 3ba1c18490..d244079d3b 100644 --- a/packages/pdf-handler/src/job.ts +++ b/packages/pdf-handler/src/job.ts @@ -17,5 +17,12 @@ type UpdatePageJobData = { } export const queueUpdatePageJob = async (data: UpdatePageJobData) => { - return queue.add(JOB_NAME, data) + return queue.add(JOB_NAME, data, { + priority: 5, + attempts: 3, + backoff: { + type: 'exponential', + delay: 1000, + }, + }) }