From 356f4424df17f8d2ccb34f894cd28b1eda46376c Mon Sep 17 00:00:00 2001 From: Mert <101130780+mertalev@users.noreply.github.com> Date: Sun, 21 May 2023 22:11:26 -0400 Subject: [PATCH] chore(server): queue handlers shouldn't increase concurrency (#2508) --- server/apps/microservices/src/processors.ts | 10 +++++----- 1 file changed, 5 insertions(+), 5 deletions(-) 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); }