Skip to content

Commit dec7a1b

Browse files
committed
fix(discovery): configure sharding every time MetricsHandler.Run runs
Signed-off-by: Walther Lee <[email protected]>
1 parent 2762759 commit dec7a1b

File tree

1 file changed

+0
-8
lines changed

1 file changed

+0
-8
lines changed

pkg/metricshandler/metrics_handler.go

Lines changed: 0 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -132,14 +132,6 @@ func (m *MetricsHandler) Run(ctx context.Context) error {
132132
return
133133
}
134134

135-
m.mtx.RLock()
136-
shardingUnchanged := m.curShard == shard && m.curTotalShards == totalShards
137-
m.mtx.RUnlock()
138-
139-
if shardingUnchanged {
140-
return
141-
}
142-
143135
m.ConfigureSharding(ctx, shard, totalShards)
144136
},
145137
UpdateFunc: func(oldo, curo interface{}) {

0 commit comments

Comments
 (0)