bulk options

tidepool-org · Dec 18, 2023 · 97216cc · 97216cc
1 parent f79a32f
commit 97216cc
Showing 1 changed file with 4 additions and 2 deletions.
diff --git a/migrations/20231128_jellyfish_migration/20231128_jellyfish_migration.go b/migrations/20231128_jellyfish_migration/20231128_jellyfish_migration.go
@@ -391,7 +391,7 @@ func (m *Migration) fetchAndUpdateBatch() bool {
 
 			updateOp := mongo.NewUpdateOneModel()
 			updateOp.SetFilter(bson.M{"_id": datumID, "modifiedTime": dDataResult["modifiedTime"]})
-			updateOp.SetUpdate(datumUpdates)
+			updateOp.SetUpdate(bson.M{"$set": datumUpdates})
 			m.updates = append(m.updates, updateOp)
 			m.lastUpdatedId = datumID
 		}
@@ -432,9 +432,11 @@ func (m *Migration) writeBatchUpdates() (int, error) {
 			log.Println("dry run so not applying changes")
 			continue
 		}
+		bulkOption := options.BulkWriteOptions{}
+		bulkOption.SetOrdered(true)
 
 		if deviceC := m.getDataCollection(); deviceC != nil {
-			results, err := deviceC.BulkWrite(m.ctx, batch)
+			results, err := deviceC.BulkWrite(m.ctx, batch, &bulkOption)
 			if err != nil {
 				log.Printf("error writing batch updates %v", err)
 				return updateCount, err