diff --git a/tempodb/blocklist/poller.go b/tempodb/blocklist/poller.go index 237aef5898b..977d8ff3de4 100644 --- a/tempodb/blocklist/poller.go +++ b/tempodb/blocklist/poller.go @@ -161,11 +161,9 @@ func (p *Poller) Do(previous *List) (PerTenant, PerTenantCompacted, error) { blocklist = PerTenant{} compactedBlocklist = PerTenantCompacted{} - tenantFailuresRemaining atomic.Int32 + tenantFailuresRemaining = atomic.NewInt32(int32(p.cfg.TolerateTenantFailures)) ) - tenantFailuresRemaining.Store(int32(p.cfg.TolerateTenantFailures)) - for _, tenantID := range tenants { // Exit early if we have exceeded our tolerance for number of failing tenants. if tenantFailuresRemaining.Load() < 0 {