Skip to content

Commit

Permalink
Correctly return func error()
Browse files Browse the repository at this point in the history
Signed-off-by: haanhvu <haanh6594@gmail.com>
  • Loading branch information
haanhvu committed Nov 4, 2022
1 parent efec433 commit 012b5b3
Showing 1 changed file with 3 additions and 3 deletions.
6 changes: 3 additions & 3 deletions cmd/thanos/receive.go
Original file line number Diff line number Diff line change
Expand Up @@ -496,7 +496,7 @@ func setupHashring(g *run.Group,
defer close(updates)
updates <- ring
<-cancel
return hashringConfigs, nil
return nil
}, func(error) {
close(cancel)
})
Expand All @@ -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.
Expand All @@ -524,7 +524,7 @@ func setupHashring(g *run.Group,
statusProber.Ready()
}
case <-cancel:
return hashringConfigs, nil
return nil
}
}
}, func(err error) {
Expand Down

0 comments on commit 012b5b3

Please sign in to comment.