diff --git a/cmd/thanos/receive.go b/cmd/thanos/receive.go index f0aa6588c8f..4b05ae941a9 100644 --- a/cmd/thanos/receive.go +++ b/cmd/thanos/receive.go @@ -496,7 +496,7 @@ func setupHashring(g *run.Group, defer close(updates) updates <- ring <-cancel - return hashringConfigs, nil + return nil }, func(error) { close(cancel) }) @@ -513,7 +513,7 @@ func setupHashring(g *run.Group, select { case h, ok := <-updates: if !ok { - return hashringConfigs, nil + return nil } webHandler.Hashring(h) // If ingestion is enabled, send a signal to TSDB to flush. @@ -524,7 +524,7 @@ func setupHashring(g *run.Group, statusProber.Ready() } case <-cancel: - return hashringConfigs, nil + return nil } } }, func(err error) {