enqueue subnets after vpc update (#1722)

kubeovn · Jul 25, 2022 · a91056a · a91056a
1 parent e895c5f
commit a91056a
Showing 1 changed file with 11 additions and 0 deletions.
diff --git a/pkg/controller/vpc.go b/pkg/controller/vpc.go
@@ -447,6 +447,17 @@ func (c *Controller) handleAddOrUpdateVpc(key string) error {
 		return err
 	}
 
+	subnets, err := c.subnetsLister.List(labels.Everything())
+	if err != nil {
+		return err
+	}
+
+	for _, subnet := range subnets {
+		if subnet.Spec.Vpc == key {
+			c.addOrUpdateSubnetQueue.Add(subnet.Name)
+		}
+	}
+
 	return nil
 }