From 3148c54e18413cf19e286de74f6c8ad90076b953 Mon Sep 17 00:00:00 2001 From: Maidul Islam Date: Wed, 28 May 2025 20:55:46 -0400 Subject: [PATCH] Revert "PIT: fix checkpoint creation to do it in batches to avoid insert fails" --- backend/src/lib/config/env.ts | 2 +- .../folder-commit/folder-commit-service.ts | 15 +++------------ 2 files changed, 4 insertions(+), 13 deletions(-) diff --git a/backend/src/lib/config/env.ts b/backend/src/lib/config/env.ts index 9e7a34232..f06de0d15 100644 --- a/backend/src/lib/config/env.ts +++ b/backend/src/lib/config/env.ts @@ -245,7 +245,7 @@ const envSchema = z DATADOG_HOSTNAME: zpStr(z.string().optional()), // PIT - PIT_CHECKPOINT_WINDOW: zpStr(z.string().optional().default("2")), + PIT_CHECKPOINT_WINDOW: zpStr(z.string().optional().default("1")), PIT_TREE_CHECKPOINT_WINDOW: zpStr(z.string().optional().default("30")), /* CORS ----------------------------------------------------------------------------- */ diff --git a/backend/src/services/folder-commit/folder-commit-service.ts b/backend/src/services/folder-commit/folder-commit-service.ts index 3e5bccfb2..21dcc3095 100644 --- a/backend/src/services/folder-commit/folder-commit-service.ts +++ b/backend/src/services/folder-commit/folder-commit-service.ts @@ -295,19 +295,10 @@ export const folderCommitServiceFactory = ({ }, tx ); - - const batchSize = 500; - const chunks = chunkArray(checkpointResources, batchSize); - - await Promise.all( - chunks.map(async (chunk) => { - await folderCheckpointResourcesDAL.insertMany( - chunk.map((resource) => ({ folderCheckpointId: newCheckpoint.id, ...resource })), - tx - ); - }) + await folderCheckpointResourcesDAL.insertMany( + checkpointResources.map((resource) => ({ folderCheckpointId: newCheckpoint.id, ...resource })), + tx ); - return latestCommitId; };