github-mirrors/immich
1
0
Fork 0
mirror of https://github.com/immich-app/immich.git synced 2026-03-23 01:29:00 +03:00
Code Issues Packages Projects Releases Wiki Activity

fix bottleneck

Browse Source
This commit is contained in:
mertalev
2026-02-14 06:28:09 -05:00
parent 0e1f61176a
commit 1989a8bec2
2 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
server/src/repositories/job.repository.ts
View File

@@ -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<DB>({ dialect: new PostgresJSDialect({ postgres: this.pool }) });
this.writeBuffer = new WriteBuffer(this.pool, (queue) => this.notify(queue));
}

4
server/src/services/storage-template.service.ts
View File

@@ -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 })