fix unit tests

pkg/controllers/resources/nodes/syncer.go

@@ -307,6 +307,15 @@ func (s *nodeSyncer) Sync(ctx *synccontext.SyncContext, event *synccontext.SyncE
 	}
 
 	s.translateUpdateBackwards(event.Host, event.Virtual)
+
+	// Set the marker of managed-by vcluster so that
+	// we skip deleting the nodes which are not managed
+	// by vcluster in `SyncToHost` function
+	if len(event.Virtual.Labels) == 0 {
+		event.Virtual.Labels = map[string]string{}
+	}
+	event.Virtual.Labels[translate.MarkerLabel] = translate.VClusterName
+
 	return ctrl.Result{}, nil
 }
 

pkg/controllers/resources/nodes/syncer_test.go

@@ -304,12 +304,14 @@ func TestSyncBothExist(t *testing.T) {
 			}
 
 			if tC.virtualNodeExists {
-				node := initialVNode.DeepCopy()
 				if len(tC.virtualInitialAnnotations) > 0 {
-					node.Annotations = tC.virtualInitialAnnotations
+					// Since we pass initialVNode to syncer.Sync, we should
+					// update the initialVNode to have annnotations as per
+					// the test case
+					initialVNode.Annotations = tC.virtualInitialAnnotations
 				}
 
-				initialObjects = append(initialObjects, node)
+				initialObjects = append(initialObjects, initialVNode)
 			}
 
 			physical.Labels = tC.hostLabel

pkg/controllers/resources/nodes/translate.go

@@ -111,11 +111,6 @@ func (s *nodeSyncer) translateUpdateBackwards(pNode *corev1.Node, vNode *corev1.
 		annotations["cluster-autoscaler.kubernetes.io/scale-down-disabled"] = "true"
 	}
 
-	// Set the marker of managed-by vcluster so that
-	// we skip deleting the nodes which are not managed
-	// by vcluster in `SyncToHost` function
-	labels[translate.MarkerLabel] = translate.VClusterName
-
 	// set annotations, spec & labels
 	vNode.Spec = *translatedSpec
 	vNode.Annotations = annotations