fix(shard-distributor): inverted condition in shard stats cleanup loop

AndreasHolt · AndreasHolt · commit db70702b16d8 · 2025-11-19T12:38:18.000+01:00
Signed-off-by: Andreas Holt &lt;6665487+AndreasHolt@users.noreply.github.com&gt;
diff --git a/service/sharddistributor/leader/process/processor.go b/service/sharddistributor/leader/process/processor.go
@@ -240,7 +240,7 @@ func (p *namespaceProcessor) runShardStatsCleanupLoop(ctx context.Context) {
 				continue
 			}
 			staleShardStats := p.identifyStaleShardStats(namespaceState)
-			if len(staleShardStats) > 0 {
+			if len(staleShardStats) == 0 {
 				// No stale shard stats to delete
 				continue
 			}

Original file line number	Diff line number	Diff line change
`@@ -240,7 +240,7 @@ func (p *namespaceProcessor) runShardStatsCleanupLoop(ctx context.Context) {`
`240`	`240`	`continue`
`241`	`241`	`}`
`242`	`242`	`staleShardStats := p.identifyStaleShardStats(namespaceState)`
`243`		`- if len(staleShardStats) > 0 {`
	`243`	`+ if len(staleShardStats) == 0 {`
`244`	`244`	`// No stale shard stats to delete`
`245`	`245`	`continue`
`246`	`246`	`}`