From 1989a8bec26c44a6ef101762fe5080f723b7d065 Mon Sep 17 00:00:00 2001 From: mertalev <101130780+mertalev@users.noreply.github.com> Date: Sat, 14 Feb 2026 06:28:09 -0500 Subject: [PATCH] fix bottleneck --- server/src/repositories/job.repository.ts | 2 +- server/src/services/storage-template.service.ts | 4 ++-- 2 files changed, 3 insertions(+), 3 deletions(-) diff --git a/server/src/repositories/job.repository.ts b/server/src/repositories/job.repository.ts index c2085f97c0..9bb7268eb1 100644 --- a/server/src/repositories/job.repository.ts +++ b/server/src/repositories/job.repository.ts @@ -141,7 +141,7 @@ export class JobRepository { } } - this.pool = this.createPgConnection({ max: 10, connection: { synchronous_commit: 'off' } }); + this.pool = this.createPgConnection({ max: 20, connection: { synchronous_commit: 'off' } }); this.db = new Kysely({ dialect: new PostgresJSDialect({ postgres: this.pool }) }); this.writeBuffer = new WriteBuffer(this.pool, (queue) => this.notify(queue)); } diff --git a/server/src/services/storage-template.service.ts b/server/src/services/storage-template.service.ts index d5020a9c5e..4d01493b14 100644 --- a/server/src/services/storage-template.service.ts +++ b/server/src/services/storage-template.service.ts @@ -134,8 +134,8 @@ export class StorageTemplateService extends BaseService { } @OnEvent({ name: 'AssetMetadataExtracted' }) - async onAssetMetadataExtracted({ source, assetId }: ArgOf<'AssetMetadataExtracted'>) { - await this.jobRepository.queue({ name: JobName.StorageTemplateMigrationSingle, data: { source, id: assetId } }); + onAssetMetadataExtracted({ source, assetId }: ArgOf<'AssetMetadataExtracted'>) { + void this.jobRepository.queue({ name: JobName.StorageTemplateMigrationSingle, data: { source, id: assetId } }); } @OnJob({ name: JobName.StorageTemplateMigrationSingle, queue: QueueName.StorageTemplateMigration })