Fix missing await.

rkistner · rkistner · commit 11a86b43c28d · 2025-02-20T13:15:35.000+02:00
diff --git a/modules/module-mongodb-storage/src/storage/implementation/MongoWriteCheckpointAPI.ts b/modules/module-mongodb-storage/src/storage/implementation/MongoWriteCheckpointAPI.ts
@@ -126,7 +126,7 @@ export async function batchCreateCustomWriteCheckpoints(
     return;
   }
 
-  db.custom_write_checkpoints.bulkWrite(
+  await db.custom_write_checkpoints.bulkWrite(
     checkpoints.map((checkpointOptions) => ({
       updateOne: {
         filter: { user_id: checkpointOptions.user_id, sync_rules_id: checkpointOptions.sync_rules_id },

Original file line number	Diff line number	Diff line change
`@@ -126,7 +126,7 @@ export async function batchCreateCustomWriteCheckpoints(`
`126`	`126`	`return;`
`127`	`127`	`}`
`128`	`128`
`129`		`- db.custom_write_checkpoints.bulkWrite(`
	`129`	`+ await db.custom_write_checkpoints.bulkWrite(`
`130`	`130`	`checkpoints.map((checkpointOptions) => ({`
`131`	`131`	`updateOne: {`
`132`	`132`	`filter: { user_id: checkpointOptions.user_id, sync_rules_id: checkpointOptions.sync_rules_id },`