fix unit test

Author: Simon-Dongnan

controller/module_deployment_controller/runtime_info_store.go

@@ -326,7 +326,7 @@ func getDeploymentMatchLabels(dep appsv1.Deployment) (eqLabels, neLabels map[str
 					if !has {
 						neLabels[expressions.Key] = neValues
 					} else {
-						neLabels[expressions.Key] = intersection(oldValues, neValues)
+						neLabels[expressions.Key] = union(oldValues, neValues)
 					}
 				}
 			}

module_tunnels/koupleless_mqtt_tunnel/mqtt_tunnel.go

@@ -127,23 +127,25 @@ func (m *MqttTunnel) Start(ctx context.Context, clientID, env string) (err error
 	}
 
 	go func() {
-		m.Cache.WaitForCacheSync(ctx)
-		vkUtils.TimedTaskWithInterval(ctx, time.Minute, func(ctx context.Context) {
-			nodeList := corev1.NodeList{}
-			envRequirement, _ := labels.NewRequirement(vkModel.LabelKeyOfEnv, selection.In, []string{m.env})
-			componentRequirement, _ := labels.NewRequirement(vkModel.LabelKeyOfComponent, selection.In, []string{vkModel.ComponentVNode})
-			m.Client.List(ctx, &nodeList, &client.ListOptions{
-				LabelSelector: labels.NewSelector().Add(*envRequirement, *componentRequirement),
-			})
-			for _, node := range nodeList.Items {
-				for _, condition := range node.Status.Conditions {
-					if condition.Type == corev1.NodeReady && condition.Status != corev1.ConditionTrue {
-						// base not ready, delete from api server
-						m.Client.Delete(ctx, &node)
+		if m.Cache != nil {
+			m.Cache.WaitForCacheSync(ctx)
+			vkUtils.TimedTaskWithInterval(ctx, time.Minute, func(ctx context.Context) {
+				nodeList := corev1.NodeList{}
+				envRequirement, _ := labels.NewRequirement(vkModel.LabelKeyOfEnv, selection.In, []string{m.env})
+				componentRequirement, _ := labels.NewRequirement(vkModel.LabelKeyOfComponent, selection.In, []string{vkModel.ComponentVNode})
+				m.Client.List(ctx, &nodeList, &client.ListOptions{
+					LabelSelector: labels.NewSelector().Add(*envRequirement, *componentRequirement),
+				})
+				for _, node := range nodeList.Items {
+					for _, condition := range node.Status.Conditions {
+						if condition.Type == corev1.NodeReady && condition.Status != corev1.ConditionTrue {
+							// base not ready, delete from api server
+							m.Client.Delete(ctx, &node)
+						}
 					}
 				}
-			}
-		})
+			})
+		}
 	}()
 
 	go func() {