fix(discovery) configure sharding every time MetricsHandler.Run runs

Signed-off-by: Walther Lee <[email protected]>
kubernetes · Aug 16, 2024 · 102f391 · 102f391
1 parent 2762759
commit 102f391
Showing 1 changed file with 0 additions and 8 deletions.
diff --git a/pkg/metricshandler/metrics_handler.go b/pkg/metricshandler/metrics_handler.go
@@ -132,14 +132,6 @@ func (m *MetricsHandler) Run(ctx context.Context) error {
 				return
 			}
 
-			m.mtx.RLock()
-			shardingUnchanged := m.curShard == shard && m.curTotalShards == totalShards
-			m.mtx.RUnlock()
-
-			if shardingUnchanged {
-				return
-			}
-
 			m.ConfigureSharding(ctx, shard, totalShards)
 		},
 		UpdateFunc: func(oldo, curo interface{}) {