diff --git a/internal/cluster/ring_engine.go b/internal/cluster/ring_engine.go index fea2ea3..6f87fdd 100644 --- a/internal/cluster/ring_engine.go +++ b/internal/cluster/ring_engine.go @@ -544,8 +544,9 @@ func (e *Engine) runCommands(ctx context.Context, tk *Token) error { "taskId": claimed.ID, "local": claimed.Local.Name, "remote": claimed.Remote.Name, }) } - log.Printf("ring[%s] restarted %s: %s→%s:%d", e.ID, claimed.ID, - claimed.Local.Name, claimed.Remote.Name, claimed.Link.RemotePort) + // Logging is the app's job (RestartFn reports the actual worker + // outcome); the ring layer stays quiet so one restart is one line + // rather than two identical ones. continue } if e.Handler != nil {