diff --git a/go/worker/storage/committee/node.go b/go/worker/storage/committee/node.go index 6b7eda4b9ac..16ccd2eda28 100644 --- a/go/worker/storage/committee/node.go +++ b/go/worker/storage/committee/node.go @@ -419,12 +419,10 @@ func (n *Node) WaitForRound(round uint64, root *storageApi.Root) (<-chan uint64, } func (n *Node) PauseCheckpointer(pause bool) error { - n.logger.Info("TRYING to pause checkpointer") if !commonFlags.DebugDontBlameOasis() { return api.ErrCantPauseCheckpointer } n.checkpointer.Pause(pause) - n.logger.Info("PAUSED checkpointer") return nil } diff --git a/go/worker/storage/committee/utils.go b/go/worker/storage/committee/utils.go index 7eb45870752..6fd61770b31 100644 --- a/go/worker/storage/committee/utils.go +++ b/go/worker/storage/committee/utils.go @@ -97,5 +97,6 @@ func (h *heartbeat) reset() { boff := backoff.NewExponentialBackOff() boff.InitialInterval = 5 * time.Second + boff.MaxElapsedTime = 0 h.Ticker = backoff.NewTicker(boff) }