reset rate limiter on no reenqueue

kubewharf · Jul 13, 2023 · a457bd4 · a457bd4
1 parent 89e78e4
commit a457bd4
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 0 deletions.
diff --git a/pkg/util/informermanager/federatedinformermanager.go b/pkg/util/informermanager/federatedinformermanager.go
@@ -146,6 +146,7 @@ func (m *federatedInformerManager) worker(ctx context.Context) {
 			m.queue.AddRateLimited(key)
 		} else {
 			logger.Error(err, "Failed to process FederatedCluster")
+			m.queue.Forget(key)
 		}
 		return
 	}

diff --git a/pkg/util/informermanager/informermanager.go b/pkg/util/informermanager/informermanager.go
@@ -133,6 +133,7 @@ func (m *informerManager) worker(ctx context.Context) {
 			m.queue.AddRateLimited(key)
 		} else {
 			logger.Error(err, "Failed to process FederatedTypeConfig")
+			m.queue.Forget(key)
 		}
 		return
 	}