Merge pull request #7644 from ywk253100/240409_list

[cherry-pick]Empty the list before next round of listing
vmware-tanzu · Apr 10, 2024 · 35177cd · 35177cd
2 parents 2c57ed8 + 27a4bfc
commit 35177cd
Showing 1 changed file with 5 additions and 0 deletions.
diff --git a/pkg/util/kube/periodical_enqueue_source.go b/pkg/util/kube/periodical_enqueue_source.go
@@ -69,6 +69,11 @@ type PeriodicalEnqueueSourceOption struct {
 func (p *PeriodicalEnqueueSource) Start(ctx context.Context, h handler.EventHandler, q workqueue.RateLimitingInterface, predicates ...predicate.Predicate) error {
 	go wait.Until(func() {
 		p.logger.Debug("enqueueing resources ...")
+		// empty the list otherwise the result of the new list call will be appended
+		if err := meta.SetList(p.objList, nil); err != nil {
+			p.logger.WithError(err).Error("error reset resource list")
+			return
+		}
 		if err := p.List(ctx, p.objList); err != nil {
 			p.logger.WithError(err).Error("error listing resources")
 			return