diff --git a/packages/backend-core/src/cache/docWritethrough.ts b/packages/backend-core/src/cache/docWritethrough.ts index f76bf0be78..51018b2317 100644 --- a/packages/backend-core/src/cache/docWritethrough.ts +++ b/packages/backend-core/src/cache/docWritethrough.ts @@ -9,12 +9,13 @@ interface ProcessDocMessage { data: Record } +const PERSIST_MAX_ATTEMPTS = 100 + export const docWritethroughProcessorQueue = createQueue( JobQueue.DOC_WRITETHROUGH_QUEUE, { jobOptions: { - // We might have plenty of 409, we want to allow running almost infinitely - attempts: Number.MAX_SAFE_INTEGER, + attempts: PERSIST_MAX_ATTEMPTS, }, } )