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; };