diff --git a/go/logic/hooks.go b/go/logic/hooks.go index 8906f62..ad55b99 100644 --- a/go/logic/hooks.go +++ b/go/logic/hooks.go @@ -138,12 +138,9 @@ func (this *HooksExecutor) onFailure() error { return this.executeHooks(onFailure) } -func (this *HooksExecutor) onStatus(statusMessage string, elapsedSeconds int64) error { - v := []string{ - fmt.Sprintf("GH_OST_STATUS='%s'", statusMessage), - fmt.Sprintf("GH_OST_ELAPSED_SECONDS='%d'", elapsedSeconds), - } - return this.executeHooks(onStatus, v...) +func (this *HooksExecutor) onStatus(statusMessage string) error { + v := fmt.Sprintf("GH_OST_STATUS='%s'", statusMessage) + return this.executeHooks(onStatus, v) } func (this *HooksExecutor) onStopReplication() error { diff --git a/go/logic/migrator.go b/go/logic/migrator.go index c44d196..799e70b 100644 --- a/go/logic/migrator.go +++ b/go/logic/migrator.go @@ -1102,7 +1102,7 @@ func (this *Migrator) printStatus(rule PrintStatusRule, writers ...io.Writer) { fmt.Fprintln(w, status) if elapsedSeconds%60 == 0 { - this.hooksExecutor.onStatus(status, elapsedSeconds) + this.hooksExecutor.onStatus(status) } }