sascha
/
immich
mirror of https://github.com/immich-app/immich.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

chore(server): queue handlers shouldn't increase concurrency (#2508)

pull/2517/head
Mert 2023-05-21 22:11:26 +07:00 committed by GitHub
parent 85c6cf4309
commit 356f4424df
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 5 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
server/apps/microservices/src/processors.ts
Unescape Escape View File

@ -68,7 +68,7 @@ export class BackgroundTaskProcessor {
export class ObjectTaggingProcessor { export class ObjectTaggingProcessor {
constructor(private smartInfoService: SmartInfoService) {} constructor(private smartInfoService: SmartInfoService) {}
@Process({ name: JobName.QUEUE_OBJECT_TAGGING, concurrency: 1 }) @Process({ name: JobName.QUEUE_OBJECT_TAGGING, concurrency: 0 })
async onQueueObjectTagging(job: Job<IBaseJob>) { async onQueueObjectTagging(job: Job<IBaseJob>) {
await this.smartInfoService.handleQueueObjectTagging(job.data); await this.smartInfoService.handleQueueObjectTagging(job.data);
} }
@ -88,7 +88,7 @@ export class ObjectTaggingProcessor {
export class FacialRecognitionProcessor { export class FacialRecognitionProcessor {
constructor(private facialRecognitionService: FacialRecognitionService) {} constructor(private facialRecognitionService: FacialRecognitionService) {}
@Process({ name: JobName.QUEUE_RECOGNIZE_FACES, concurrency: 1 }) @Process({ name: JobName.QUEUE_RECOGNIZE_FACES, concurrency: 0 })
async onQueueRecognizeFaces(job: Job<IBaseJob>) { async onQueueRecognizeFaces(job: Job<IBaseJob>) {
await this.facialRecognitionService.handleQueueRecognizeFaces(job.data); await this.facialRecognitionService.handleQueueRecognizeFaces(job.data);
} }
@ -108,7 +108,7 @@ export class FacialRecognitionProcessor {
export class ClipEncodingProcessor { export class ClipEncodingProcessor {
constructor(private smartInfoService: SmartInfoService) {} constructor(private smartInfoService: SmartInfoService) {}
@Process({ name: JobName.QUEUE_ENCODE_CLIP, concurrency: 1 }) @Process({ name: JobName.QUEUE_ENCODE_CLIP, concurrency: 0 })
async onQueueClipEncoding(job: Job<IBaseJob>) { async onQueueClipEncoding(job: Job<IBaseJob>) {
await this.smartInfoService.handleQueueEncodeClip(job.data); await this.smartInfoService.handleQueueEncodeClip(job.data);
} }
@ -188,7 +188,7 @@ export class StorageTemplateMigrationProcessor {
export class ThumbnailGeneratorProcessor { export class ThumbnailGeneratorProcessor {
constructor(private mediaService: MediaService) {} constructor(private mediaService: MediaService) {}
@Process({ name: JobName.QUEUE_GENERATE_THUMBNAILS, concurrency: 1 }) @Process({ name: JobName.QUEUE_GENERATE_THUMBNAILS, concurrency: 0 })
async onQueueGenerateThumbnails(job: Job<IBaseJob>) { async onQueueGenerateThumbnails(job: Job<IBaseJob>) {
await this.mediaService.handleQueueGenerateThumbnails(job.data); await this.mediaService.handleQueueGenerateThumbnails(job.data);
} }
@ -208,7 +208,7 @@ export class ThumbnailGeneratorProcessor {
export class VideoTranscodeProcessor { export class VideoTranscodeProcessor {
constructor(private mediaService: MediaService) {} constructor(private mediaService: MediaService) {}
@Process({ name: JobName.QUEUE_VIDEO_CONVERSION, concurrency: 1 }) @Process({ name: JobName.QUEUE_VIDEO_CONVERSION, concurrency: 0 })
async onQueueVideoConversion(job: Job<IBaseJob>): Promise<void> { async onQueueVideoConversion(job: Job<IBaseJob>): Promise<void> {
await this.mediaService.handleQueueVideoConversion(job.data); await this.mediaService.handleQueueVideoConversion(job.data);
} }