diff --git a/migrations/20231128_jellyfish_migration/20231128_jellyfish_migration.go b/migrations/20231128_jellyfish_migration/20231128_jellyfish_migration.go index 84430b88f..cec300576 100644 --- 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 index 1aa2159ba..2bdba5a4f 100644 --- 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 }