diff --git a/go/logic/migrator.go b/go/logic/migrator.go index 799e70b..f35090b 100644 --- a/go/logic/migrator.go +++ b/go/logic/migrator.go @@ -1026,7 +1026,9 @@ func (this *Migrator) printStatus(rule PrintStatusRule, writers ...io.Writer) { } else { progressPct = 100.0 * float64(totalRowsCopied) / float64(rowsEstimate) } - + if atomic.LoadInt64(&this.rowCopyCompleteFlag) == 1 { + progressPct = 100.0 + } // Before status, let's see if we should print a nice reminder for what exactly we're doing here. shouldPrintMigrationStatusHint := (elapsedSeconds%600 == 0) if rule == ForcePrintStatusAndHintRule {