diff --git a/go/logic/applier.go b/go/logic/applier.go index a7edaed24..b3b77e98d 100644 --- a/go/logic/applier.go +++ b/go/logic/applier.go @@ -574,6 +574,7 @@ func (this *Applier) InitiateHeartbeat() { continue } if err := injectHeartbeat(); err != nil { + this.migrationContext.PanicAbort <- fmt.Errorf("injectHeartbeat writing failed %d times, last error: %w", numSuccessiveFailures, err) return } }