diff --git a/migrations/20231128_jellyfish_migration/20231128_jellyfish_migration.go b/migrations/20231128_jellyfish_migration/20231128_jellyfish_migration.go index 9203f92e0..d3aa7340c 100644 --- a/migrations/20231128_jellyfish_migration/20231128_jellyfish_migration.go +++ b/migrations/20231128_jellyfish_migration/20231128_jellyfish_migration.go @@ -217,7 +217,7 @@ func (m *Migration) execute() error { func (m *Migration) getOplogDuration() (time.Duration, error) { type MongoMetaData struct { - Wall int64 `json:"wall"` + Wall time.Time `json:"wall"` } log.Println("checking oplog duration ") @@ -239,9 +239,9 @@ func (m *Migration) getOplogDuration() (time.Duration, error) { log.Printf("newest walltime mongo err %v", err) return 0, err } - oldestT := time.UnixMilli(oldest.Wall) - newestT := time.UnixMilli(newest.Wall) - oplogDuration := newestT.Sub(oldestT) + //oldestT := time.UnixMilli(oldest.Wall) + //newestT := time.UnixMilli(newest.Wall) + oplogDuration := newest.Wall.Sub(oldest.Wall) log.Printf("oplog duration is currently: %v", oplogDuration) return oplogDuration, nil }