diff --git a/server/apps/microservices/src/processors.ts b/server/apps/microservices/src/processors.ts index 22133718ba..0a4b18b5e5 100644 --- a/server/apps/microservices/src/processors.ts +++ b/server/apps/microservices/src/processors.ts @@ -68,7 +68,7 @@ export class BackgroundTaskProcessor { export class ObjectTaggingProcessor { constructor(private smartInfoService: SmartInfoService) {} - @Process({ name: JobName.QUEUE_OBJECT_TAGGING, concurrency: 1 }) + @Process({ name: JobName.QUEUE_OBJECT_TAGGING, concurrency: 0 }) async onQueueObjectTagging(job: Job) { await this.smartInfoService.handleQueueObjectTagging(job.data); } @@ -88,7 +88,7 @@ export class ObjectTaggingProcessor { export class FacialRecognitionProcessor { constructor(private facialRecognitionService: FacialRecognitionService) {} - @Process({ name: JobName.QUEUE_RECOGNIZE_FACES, concurrency: 1 }) + @Process({ name: JobName.QUEUE_RECOGNIZE_FACES, concurrency: 0 }) async onQueueRecognizeFaces(job: Job) { await this.facialRecognitionService.handleQueueRecognizeFaces(job.data); } @@ -108,7 +108,7 @@ export class FacialRecognitionProcessor { export class ClipEncodingProcessor { constructor(private smartInfoService: SmartInfoService) {} - @Process({ name: JobName.QUEUE_ENCODE_CLIP, concurrency: 1 }) + @Process({ name: JobName.QUEUE_ENCODE_CLIP, concurrency: 0 }) async onQueueClipEncoding(job: Job) { await this.smartInfoService.handleQueueEncodeClip(job.data); } @@ -188,7 +188,7 @@ export class StorageTemplateMigrationProcessor { export class ThumbnailGeneratorProcessor { constructor(private mediaService: MediaService) {} - @Process({ name: JobName.QUEUE_GENERATE_THUMBNAILS, concurrency: 1 }) + @Process({ name: JobName.QUEUE_GENERATE_THUMBNAILS, concurrency: 0 }) async onQueueGenerateThumbnails(job: Job) { await this.mediaService.handleQueueGenerateThumbnails(job.data); } @@ -208,7 +208,7 @@ export class ThumbnailGeneratorProcessor { export class VideoTranscodeProcessor { constructor(private mediaService: MediaService) {} - @Process({ name: JobName.QUEUE_VIDEO_CONVERSION, concurrency: 1 }) + @Process({ name: JobName.QUEUE_VIDEO_CONVERSION, concurrency: 0 }) async onQueueVideoConversion(job: Job): Promise { await this.mediaService.handleQueueVideoConversion(job.data); }