add key to queue

2022-06-09 11:13:56 +08:00
parent e97f27e580
commit 098b77fb4c
1 changed files with 3 additions and 3 deletions
--- a/pkg/controller/cluster/cluster_controller.go
+++ b/pkg/controller/cluster/cluster_controller.go
@@ -297,10 +297,10 @@ func (c *clusterController) resyncClusters() error {
 	}

 	for _, cluster := range clusters {
-		if err = c.syncCluster(cluster.Name); err != nil {
-			klog.Warningf("failed to sync cluster %s: %s", cluster.Name, err)
-		}
+		key, _ := cache.MetaNamespaceKeyFunc(cluster)
+		c.queue.Add(key)
 	}
+
 	return nil
 }