look for the cm after the lb is created

This commit is contained in:
upodroid 2023-11-09 20:39:42 -06:00
parent 8a9b209cb1
commit 60520b6d4a

View File

@ -77,11 +77,6 @@ var _ = common.SIGDescribe("Firewall rule", func() {
firewallTestSourceRanges := []string{"0.0.0.0/1", "128.0.0.0/1"} firewallTestSourceRanges := []string{"0.0.0.0/1", "128.0.0.0/1"}
serviceName := "firewall-test-loadbalancer" serviceName := "firewall-test-loadbalancer"
ginkgo.By("Getting cluster ID")
clusterID, err := gce.GetClusterID(ctx, cs)
framework.ExpectNoError(err)
framework.Logf("Got cluster ID: %v", clusterID)
jig := e2eservice.NewTestJig(cs, ns, serviceName) jig := e2eservice.NewTestJig(cs, ns, serviceName)
nodeList, err := e2enode.GetBoundedReadySchedulableNodes(ctx, cs, e2eservice.MaxNodesForEndpointsTests) nodeList, err := e2enode.GetBoundedReadySchedulableNodes(ctx, cs, e2eservice.MaxNodesForEndpointsTests)
framework.ExpectNoError(err) framework.ExpectNoError(err)
@ -98,6 +93,13 @@ var _ = common.SIGDescribe("Firewall rule", func() {
svc.Spec.LoadBalancerSourceRanges = firewallTestSourceRanges svc.Spec.LoadBalancerSourceRanges = firewallTestSourceRanges
}) })
framework.ExpectNoError(err) framework.ExpectNoError(err)
// This configmap is guaranteed to exist after a Loadbalancer type service is created
ginkgo.By("Getting cluster ID")
clusterID, err := gce.GetClusterID(ctx, cs)
framework.ExpectNoError(err)
framework.Logf("Got cluster ID: %v", clusterID)
defer func() { defer func() {
_, err = jig.UpdateService(ctx, func(svc *v1.Service) { _, err = jig.UpdateService(ctx, func(svc *v1.Service) {
svc.Spec.Type = v1.ServiceTypeNodePort svc.Spec.Type = v1.ServiceTypeNodePort