diff --git a/apps/server/src/core/attachment/processors/attachment.processor.ts b/apps/server/src/core/attachment/processors/attachment.processor.ts index 66c9f328..bcf8a08a 100644 --- a/apps/server/src/core/attachment/processors/attachment.processor.ts +++ b/apps/server/src/core/attachment/processors/attachment.processor.ts @@ -67,9 +67,15 @@ export class AttachmentProcessor extends WorkerHost implements OnModuleDestroy { @OnWorkerEvent('failed') onError(job: Job) { - this.logger.error( - `Error processing ${job.name} job. Reason: ${job.failedReason}`, - ); + if (job.name === QueueJob.ATTACHMENT_INDEX_CONTENT) { + this.logger.debug( + `Error processing ${job.name} job for attachment ${job.data?.attachmentId}. Reason: ${job.failedReason}`, + ); + } else { + this.logger.error( + `Error processing ${job.name} job. Reason: ${job.failedReason}`, + ); + } } @OnWorkerEvent('completed') diff --git a/apps/server/src/ee b/apps/server/src/ee index 3f219dd5..e71f70c2 160000 --- a/apps/server/src/ee +++ b/apps/server/src/ee @@ -1 +1 @@ -Subproject commit 3f219dd5ccbbd3edfd3aafb78b63a11697c9b864 +Subproject commit e71f70c29950efc02f9fe795b7d4b4c9d1060db4 diff --git a/apps/server/src/integrations/import/services/import-attachment.service.ts b/apps/server/src/integrations/import/services/import-attachment.service.ts index 2b3bfa43..660239eb 100644 --- a/apps/server/src/integrations/import/services/import-attachment.service.ts +++ b/apps/server/src/integrations/import/services/import-attachment.service.ts @@ -804,7 +804,7 @@ export class ImportAttachmentService { QueueJob.ATTACHMENT_INDEX_CONTENT, { attachmentId }, { - attempts: 2, + attempts: 1, backoff: { type: 'exponential', delay: 30 * 1000,