Adding ETA starting at 2% progress

github · May 5, 2016 · 6528010 · 6528010
1 parent ee673e2
commit 6528010
Showing 1 changed file with 12 additions and 0 deletions.
diff --git a/go/logic/migrator.go b/go/logic/migrator.go
@@ -550,6 +550,18 @@ func (this *Migrator) printStatus() {
 	eta := "N/A"
 	if isThrottled, throttleReason := this.migrationContext.IsThrottled(); isThrottled {
 		eta = fmt.Sprintf("throttled, %s", throttleReason)
+	} else if progressPct > 100.0 {
+		eta = "Due"
+	} else if progressPct >= 2.0 {
+		elapsedRowCopySeconds := this.migrationContext.ElapsedRowCopyTime().Seconds()
+		totalExpectedSeconds := elapsedRowCopySeconds * float64(rowsEstimate) / float64(totalRowsCopied)
+		etaSeconds := totalExpectedSeconds - elapsedRowCopySeconds
+		etaDuration := time.Duration(etaSeconds) * time.Second
+		if etaDuration >= 0 {
+			eta = base.PrettifyDurationOutput(etaDuration)
+		} else {
+			eta = "Due"
+		}
 	}
 	status := fmt.Sprintf("Copy: %d/%d %.1f%%; Applied: %d; Backlog: %d/%d; Elapsed: %+v(copy), %+v(total); ETA: %s",
 		totalRowsCopied, rowsEstimate, progressPct,