fix: delete daemonset's pod in vitural node

Signed-off-by: renxiangyu <[email protected]>
kosmos-io · Dec 8, 2023 · 2e473f5 · 2e473f5
1 parent 03f7523
commit 2e473f5
Showing 1 changed file with 5 additions and 1 deletion.
diff --git a/pkg/clustertree/cluster-manager/controllers/pod/root_pod_controller.go b/pkg/clustertree/cluster-manager/controllers/pod/root_pod_controller.go
@@ -248,6 +248,10 @@ func (r *RootPodReconciler) SetupWithManager(mgr manager.Manager) error {
 							return true
 						}
 					}
+					_, has := p.Annotations[utils.KosmosNodeOwnedByClusterAnnotations]
+					if (!p.DeletionTimestamp.IsZero()) && (strings.HasPrefix(p.Spec.NodeName, utils.KosmosNodePrefix) || has) {
+						return true
+					}
 					return false
 				}
 			}
@@ -805,7 +809,7 @@ func (r *RootPodReconciler) DeletePodInLeafCluster(ctx context.Context, lr *leaf
 	leafPod := &corev1.Pod{}
 
 	cleanRootPodFunc := func() error {
-		return DeletePodInRootCluster(ctx, rootnamespacedname, r.Client)
+		return DeletePodInRootCluster(ctx, rootnamespacedname, r.RootClient)
 	}
 
 	err := lr.Client.Get(ctx, rootnamespacedname, leafPod)