This commit is contained in:
Philipinho
2025-09-04 15:07:01 -07:00
parent 091e790b83
commit dc0650289d
3 changed files with 11 additions and 5 deletions
@@ -67,10 +67,16 @@ export class AttachmentProcessor extends WorkerHost implements OnModuleDestroy {
@OnWorkerEvent('failed') @OnWorkerEvent('failed')
onError(job: Job) { onError(job: Job) {
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( this.logger.error(
`Error processing ${job.name} job. Reason: ${job.failedReason}`, `Error processing ${job.name} job. Reason: ${job.failedReason}`,
); );
} }
}
@OnWorkerEvent('completed') @OnWorkerEvent('completed')
onCompleted(job: Job) { onCompleted(job: Job) {
@@ -804,7 +804,7 @@ export class ImportAttachmentService {
QueueJob.ATTACHMENT_INDEX_CONTENT, QueueJob.ATTACHMENT_INDEX_CONTENT,
{ attachmentId }, { attachmentId },
{ {
attempts: 2, attempts: 1,
backoff: { backoff: {
type: 'exponential', type: 'exponential',
delay: 30 * 1000, delay: 30 * 1000,