remove testing cap

tidepool-org · Dec 18, 2023 · 0364865 · 0364865
1 parent 5e1acbe
commit 0364865
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 17 deletions.
diff --git a/migrations/20231128_jellyfish_migration/20231128_jellyfish_migration.go b/migrations/20231128_jellyfish_migration/20231128_jellyfish_migration.go
@@ -183,7 +183,7 @@ func (m *Migration) prepare() error {
 
 func (m *Migration) execute() error {
 	totalMigrated := 0
-	testingCapSize := 300
+	//testingCapSize := 300
 	for m.fetchAndUpdateBatch() {
 		updatedCount, err := m.writeBatchUpdates()
 		if err != nil {
@@ -192,10 +192,10 @@ func (m *Migration) execute() error {
 		}
 		totalMigrated = totalMigrated + updatedCount
 		log.Printf("migrated %d for a total of %d migrated items", updatedCount, totalMigrated)
-		if totalMigrated >= testingCapSize {
-			log.Printf("migrated %d docs up to cap so exiting", totalMigrated)
-			break
-		}
+		// if totalMigrated >= testingCapSize {
+		// 	log.Printf("migrated %d docs up to cap so exiting", totalMigrated)
+		// 	break
+		// }
 	}
 	return nil
 }

diff --git a/migrations/20231128_jellyfish_migration/utils/utils.go b/migrations/20231128_jellyfish_migration/utils/utils.go
@@ -99,7 +99,6 @@ func GetDatumUpdates(bsonData bson.M) (string, bson.M, error) {
 			return errorDebug(datumID, err)
 		}
 		identityFields, err = datum.IdentityFields()
-		log.Printf("basal %s id  %v", datumID, identityFields)
 		if err != nil {
 			return errorDebug(datumID, err)
 		}
@@ -110,7 +109,6 @@ func GetDatumUpdates(bsonData bson.M) (string, bson.M, error) {
 			return errorDebug(datumID, err)
 		}
 		identityFields, err = datum.IdentityFields()
-		log.Printf("bolus %s id  %v", datumID, identityFields)
 		if err != nil {
 			return errorDebug(datumID, err)
 		}
@@ -121,7 +119,6 @@ func GetDatumUpdates(bsonData bson.M) (string, bson.M, error) {
 			return errorDebug(datumID, err)
 		}
 		identityFields, err = datum.IdentityFields()
-		log.Printf("device %s id  %v", datumID, identityFields)
 		if err != nil {
 			return errorDebug(datumID, err)
 		}
@@ -132,7 +129,6 @@ func GetDatumUpdates(bsonData bson.M) (string, bson.M, error) {
 			return errorDebug(datumID, err)
 		}
 		identityFields, err = datum.IdentityFields()
-		log.Printf("pump %s id  %v", datumID, identityFields)
 		if err != nil {
 			return errorDebug(datumID, err)
 		}
@@ -164,8 +160,6 @@ func GetDatumUpdates(bsonData bson.M) (string, bson.M, error) {
 			datum.Value = &val
 		}
 		identityFields, err = datum.IdentityFields()
-
-		log.Printf("smbg %s id  %v", datumID, identityFields)
 		if err != nil {
 			return errorDebug(datumID, err)
 		}
@@ -182,7 +176,6 @@ func GetDatumUpdates(bsonData bson.M) (string, bson.M, error) {
 			datum.Value = &val
 		}
 		identityFields, err = datum.IdentityFields()
-		log.Printf("ketone %s id  %v", datumID, identityFields)
 		if err != nil {
 			return errorDebug(datumID, err)
 		}
@@ -199,7 +192,6 @@ func GetDatumUpdates(bsonData bson.M) (string, bson.M, error) {
 			datum.Value = &val
 		}
 		identityFields, err = datum.IdentityFields()
-		log.Printf("cbg %s id  %v", datumID, identityFields)
 		if err != nil {
 			return errorDebug(datumID, err)
 		}
@@ -210,7 +202,6 @@ func GetDatumUpdates(bsonData bson.M) (string, bson.M, error) {
 			return errorDebug(datumID, err)
 		}
 		identityFields, err = datum.IdentityFields()
-		log.Printf("default %s id  %v", datumID, identityFields)
 		if err != nil {
 			return errorDebug(datumID, err)
 		}
@@ -221,8 +212,5 @@ func GetDatumUpdates(bsonData bson.M) (string, bson.M, error) {
 		return errorDebug(datumID, err)
 	}
 	updates["_deduplicator"] = bson.M{"hash": hash}
-
-	log.Printf("datum %s updates  %v", datumID, updates)
-
 	return datumID, updates, nil
 }