diff --git a/apps/nestjs-backend/src/features/record/open-api/record-open-api.service.ts b/apps/nestjs-backend/src/features/record/open-api/record-open-api.service.ts index 1fa9e0d28b..a75c671d30 100644 --- a/apps/nestjs-backend/src/features/record/open-api/record-open-api.service.ts +++ b/apps/nestjs-backend/src/features/record/open-api/record-open-api.service.ts @@ -160,10 +160,15 @@ export class RecordOpenApiService { return res; } + @retryOnDeadlock() async simpleUpdateRecords(tableId: string, updateRecordsRo: IUpdateRecordsRo) { - return await this.recordModifyService.simpleUpdateRecords( - tableId, - updateRecordsRo as IUpdateRecordsInternalRo + return await this.prismaService.$tx( + async () => + this.recordModifyService.simpleUpdateRecords( + tableId, + updateRecordsRo as IUpdateRecordsInternalRo + ), + { timeout: this.thresholdConfig.bigTransactionTimeout } ); }