Skip to content

Commit 1d03c90

Browse files
k8s-ci-robotk8s-ci-robot
authored
Merge pull request #4061 from Ankitasw/fix-service-quota
[E2E] Fix service quotas for EventBridge rules
2 parents ba9ccd9 + 0a65fb7 commit 1d03c90

10 files changed

+63
-46
lines changed

‎test/e2e/shared/aws.go

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -411,6 +411,9 @@ func createCloudFormationStack(prov client.ConfigProvider, t *cfn_bootstrap.Temp
411411

412412
Eventually(func() bool {
413413
err := cfnSvc.ReconcileBootstrapStack(t.Spec.StackName, *renderCustomCloudFormation(t), tags, true)
414+
if err != nil {
415+
By(fmt.Sprintf("Error reconciling Cloud formation stack %v", err))
416+
}
414417
output, err1 := CFN.DescribeStackEvents(&cfn.DescribeStackEventsInput{StackName: aws.String(t.Spec.StackName), NextToken: aws.String("1")})
415418
By("========= Stack Event Output Begin =========")
416419
for _, event := range output.StackEvents {

‎test/e2e/shared/defaults.go

Lines changed: 7 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -185,6 +185,13 @@ func getLimitedResources() map[string]*ServiceQuota {
185185
DesiredMinimumValue: 50,
186186
}
187187

188+
serviceQuotas["eventBridge-rules"] = &ServiceQuota{
189+
ServiceCode: "events",
190+
QuotaName: "Maximum number of rules an account can have per event bus",
191+
QuotaCode: "L-244521F2",
192+
DesiredMinimumValue: 500,
193+
}
194+
188195
return serviceQuotas
189196
}
190197

‎test/e2e/shared/resource.go

Lines changed: 24 additions & 17 deletions
Original file line numberDiff line numberDiff line change
@@ -35,14 +35,15 @@ import (
3535
)
3636

3737
type TestResource struct {
38-
EC2Normal int `json:"ec2-normal"`
39-
VPC int `json:"vpc"`
40-
EIP int `json:"eip"`
41-
IGW int `json:"igw"`
42-
NGW int `json:"ngw"`
43-
ClassicLB int `json:"classiclb"`
44-
EC2GPU int `json:"ec2-GPU"`
45-
VolumeGP2 int `json:"volume-GP2"`
38+
EC2Normal int `json:"ec2-normal"`
39+
VPC int `json:"vpc"`
40+
EIP int `json:"eip"`
41+
IGW int `json:"igw"`
42+
NGW int `json:"ngw"`
43+
ClassicLB int `json:"classiclb"`
44+
EC2GPU int `json:"ec2-GPU"`
45+
VolumeGP2 int `json:"volume-GP2"`
46+
EventBridgeRules int `json:"eventBridge-rules"`
4647
}
4748

4849
func WriteResourceQuotesToFile(logPath string, serviceQuotas map[string]*ServiceQuota) {
@@ -52,14 +53,15 @@ func WriteResourceQuotesToFile(logPath string, serviceQuotas map[string]*Service
5253
}
5354

5455
resources := TestResource{
55-
EC2Normal: serviceQuotas["ec2-normal"].Value,
56-
VPC: serviceQuotas["vpc"].Value,
57-
EIP: serviceQuotas["eip"].Value,
58-
IGW: serviceQuotas["igw"].Value,
59-
NGW: serviceQuotas["ngw"].Value,
60-
ClassicLB: serviceQuotas["classiclb"].Value,
61-
EC2GPU: serviceQuotas["ec2-GPU"].Value,
62-
VolumeGP2: serviceQuotas["volume-GP2"].Value,
56+
EC2Normal: serviceQuotas["ec2-normal"].Value,
57+
VPC: serviceQuotas["vpc"].Value,
58+
EIP: serviceQuotas["eip"].Value,
59+
IGW: serviceQuotas["igw"].Value,
60+
NGW: serviceQuotas["ngw"].Value,
61+
ClassicLB: serviceQuotas["classiclb"].Value,
62+
EC2GPU: serviceQuotas["ec2-GPU"].Value,
63+
VolumeGP2: serviceQuotas["volume-GP2"].Value,
64+
EventBridgeRules: serviceQuotas["eventBridge-rules"].Value,
6365
}
6466
data, err := yaml.Marshal(resources)
6567
Expect(err).NotTo(HaveOccurred())
@@ -82,7 +84,7 @@ func WriteAWSResourceQuotesToFile(logPath string, serviceQuotas map[string]*serv
8284
}
8385

8486
func (r *TestResource) String() string {
85-
return fmt.Sprintf("{ec2-normal:%v, vpc:%v, eip:%v, ngw:%v, igw:%v, classiclb:%v, ec2-GPU:%v, volume-gp2:%v}", r.EC2Normal, r.VPC, r.EIP, r.NGW, r.IGW, r.ClassicLB, r.EC2GPU, r.VolumeGP2)
87+
return fmt.Sprintf("{ec2-normal:%v, vpc:%v, eip:%v, ngw:%v, igw:%v, classiclb:%v, ec2-GPU:%v, volume-gp2:%v, eventBridge-rules:%v}", r.EC2Normal, r.VPC, r.EIP, r.NGW, r.IGW, r.ClassicLB, r.EC2GPU, r.VolumeGP2, r.EventBridgeRules)
8688
}
8789

8890
func (r *TestResource) WriteRequestedResources(e2eCtx *E2EContext, testName string) {
@@ -149,6 +151,9 @@ func (r *TestResource) doesSatisfy(request *TestResource) bool {
149151
if request.VolumeGP2 != 0 && r.VolumeGP2 < request.VolumeGP2 {
150152
return false
151153
}
154+
if request.EventBridgeRules != 0 && r.EventBridgeRules < request.EventBridgeRules {
155+
return false
156+
}
152157
return true
153158
}
154159

@@ -161,6 +166,7 @@ func (r *TestResource) acquire(request *TestResource) {
161166
r.ClassicLB -= request.ClassicLB
162167
r.EC2GPU -= request.EC2GPU
163168
r.VolumeGP2 -= request.VolumeGP2
169+
r.EventBridgeRules -= request.EventBridgeRules
164170
}
165171

166172
func (r *TestResource) release(request *TestResource) {
@@ -172,6 +178,7 @@ func (r *TestResource) release(request *TestResource) {
172178
r.ClassicLB += request.ClassicLB
173179
r.EC2GPU += request.EC2GPU
174180
r.VolumeGP2 += request.VolumeGP2
181+
r.EventBridgeRules += request.EventBridgeRules
175182
}
176183

177184
func AcquireResources(request *TestResource, nodeNum int, fileLock *flock.Flock) error {

‎test/e2e/suites/gc_unmanaged/gc_unmanaged_test.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -57,7 +57,7 @@ var _ = ginkgo.Context("[unmanaged] [gc]", func() {
5757
Expect(e2eCtx.E2EConfig).ToNot(BeNil(), "Invalid argument. e2eConfig can't be nil when calling %s spec", specName)
5858
Expect(e2eCtx.E2EConfig.Variables).To(HaveKey(shared.KubernetesVersion))
5959

60-
requiredResources = &shared.TestResource{EC2Normal: 2 * e2eCtx.Settings.InstanceVCPU, IGW: 1, NGW: 1, VPC: 1, ClassicLB: 1, EIP: 1}
60+
requiredResources = &shared.TestResource{EC2Normal: 2 * e2eCtx.Settings.InstanceVCPU, IGW: 1, NGW: 1, VPC: 1, ClassicLB: 1, EIP: 1, EventBridgeRules: 50}
6161
requiredResources.WriteRequestedResources(e2eCtx, specName)
6262
Expect(shared.AcquireResources(requiredResources, ginkgo.GinkgoParallelProcess(), flock.New(shared.ResourceQuotaFilePath))).To(Succeed())
6363
defer shared.ReleaseResources(requiredResources, ginkgo.GinkgoParallelProcess(), flock.New(shared.ResourceQuotaFilePath))

‎test/e2e/suites/unmanaged/unmanaged_CAPI_clusterclass_test.go

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -44,7 +44,7 @@ var _ = ginkgo.Context("[unmanaged] [Cluster API Framework] [ClusterClass]", fun
4444
ginkgo.Describe("Self Hosted Spec [ClusterClass]", func() {
4545
ginkgo.BeforeEach(func() {
4646
// As the resources cannot be defined by the It() clause in CAPI tests, using the largest values required for all It() tests in this CAPI test.
47-
requiredResources = &shared.TestResource{EC2Normal: 2 * e2eCtx.Settings.InstanceVCPU, IGW: 1, NGW: 1, VPC: 1, ClassicLB: 1, EIP: 1}
47+
requiredResources = &shared.TestResource{EC2Normal: 2 * e2eCtx.Settings.InstanceVCPU, IGW: 1, NGW: 1, VPC: 1, ClassicLB: 1, EIP: 1, EventBridgeRules: 50}
4848
requiredResources.WriteRequestedResources(e2eCtx, "capi-clusterctl-self-hosted-test-clusterclass")
4949
Expect(shared.AcquireResources(requiredResources, ginkgo.GinkgoParallelProcess(), flock.New(shared.ResourceQuotaFilePath))).To(Succeed())
5050
})
@@ -68,7 +68,7 @@ var _ = ginkgo.Context("[unmanaged] [Cluster API Framework] [ClusterClass]", fun
6868
ginkgo.Describe("Cluster Upgrade Spec - HA control plane with workers [K8s-Upgrade] [ClusterClass]", func() {
6969
ginkgo.BeforeEach(func() {
7070
// As the resources cannot be defined by the It() clause in CAPI tests, using the largest values required for all It() tests in this CAPI test.
71-
requiredResources = &shared.TestResource{EC2Normal: 5 * e2eCtx.Settings.InstanceVCPU, IGW: 2, NGW: 2, VPC: 2, ClassicLB: 2, EIP: 2}
71+
requiredResources = &shared.TestResource{EC2Normal: 5 * e2eCtx.Settings.InstanceVCPU, IGW: 2, NGW: 2, VPC: 2, ClassicLB: 2, EIP: 2, EventBridgeRules: 50}
7272
requiredResources.WriteRequestedResources(e2eCtx, "capi-cluster-upgrade-clusterclass-test")
7373
Expect(shared.AcquireResources(requiredResources, ginkgo.GinkgoParallelProcess(), flock.New(shared.ResourceQuotaFilePath))).To(Succeed())
7474
})
@@ -94,7 +94,7 @@ var _ = ginkgo.Context("[unmanaged] [Cluster API Framework] [ClusterClass]", fun
9494
ginkgo.Describe("ClusterClass Changes Spec - SSA immutability checks [ClusterClass]", func() {
9595
ginkgo.BeforeEach(func() {
9696
// As the resources cannot be defined by the It() clause in CAPI tests, using the largest values required for all It() tests in this CAPI test.
97-
requiredResources = &shared.TestResource{EC2Normal: 5 * e2eCtx.Settings.InstanceVCPU, IGW: 2, NGW: 2, VPC: 2, ClassicLB: 2, EIP: 2}
97+
requiredResources = &shared.TestResource{EC2Normal: 5 * e2eCtx.Settings.InstanceVCPU, IGW: 2, NGW: 2, VPC: 2, ClassicLB: 2, EIP: 2, EventBridgeRules: 50}
9898
requiredResources.WriteRequestedResources(e2eCtx, "capi-cluster-ssa-clusterclass-test")
9999
Expect(shared.AcquireResources(requiredResources, ginkgo.GinkgoParallelProcess(), flock.New(shared.ResourceQuotaFilePath))).To(Succeed())
100100
})

‎test/e2e/suites/unmanaged/unmanaged_CAPI_quick_clusterclass_test.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -49,7 +49,7 @@ var _ = ginkgo.Context("[unmanaged] [Cluster API Framework] [smoke] [PR-Blocking
4949
ginkgo.Describe("Running the quick-start spec with ClusterClass", func() {
5050
ginkgo.BeforeEach(func() {
5151
// As the resources cannot be defined by the It() clause in CAPI tests, using the largest values required for all It() tests in this CAPI test.
52-
requiredResources = &shared.TestResource{EC2Normal: 2 * e2eCtx.Settings.InstanceVCPU, IGW: 1, NGW: 1, VPC: 1, ClassicLB: 1, EIP: 3}
52+
requiredResources = &shared.TestResource{EC2Normal: 2 * e2eCtx.Settings.InstanceVCPU, IGW: 1, NGW: 1, VPC: 1, ClassicLB: 1, EIP: 3, EventBridgeRules: 50}
5353
requiredResources.WriteRequestedResources(e2eCtx, "capi-quick-start-clusterclass-test")
5454
Expect(shared.AcquireResources(requiredResources, ginkgo.GinkgoParallelProcess(), flock.New(shared.ResourceQuotaFilePath))).To(Succeed())
5555
})

‎test/e2e/suites/unmanaged/unmanaged_CAPI_quick_test.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -48,7 +48,7 @@ var _ = ginkgo.Context("[unmanaged] [Cluster API Framework] [smoke] [PR-Blocking
4848
ginkgo.Describe("Running the quick-start spec", func() {
4949
ginkgo.BeforeEach(func() {
5050
// As the resources cannot be defined by the It() clause in CAPI tests, using the largest values required for all It() tests in this CAPI test.
51-
requiredResources = &shared.TestResource{EC2Normal: 2 * e2eCtx.Settings.InstanceVCPU, IGW: 1, NGW: 1, VPC: 1, ClassicLB: 1, EIP: 3}
51+
requiredResources = &shared.TestResource{EC2Normal: 2 * e2eCtx.Settings.InstanceVCPU, IGW: 1, NGW: 1, VPC: 1, ClassicLB: 1, EIP: 3, EventBridgeRules: 50}
5252
requiredResources.WriteRequestedResources(e2eCtx, "capi-quick-start-test")
5353
Expect(shared.AcquireResources(requiredResources, ginkgo.GinkgoParallelProcess(), flock.New(shared.ResourceQuotaFilePath))).To(Succeed())
5454
})

‎test/e2e/suites/unmanaged/unmanaged_CAPI_test.go

Lines changed: 7 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -45,7 +45,7 @@ var _ = ginkgo.Context("[unmanaged] [Cluster API Framework]", func() {
4545
ginkgo.Describe("Machine Remediation Spec", func() {
4646
ginkgo.BeforeEach(func() {
4747
// As the resources cannot be defined by the It() clause in CAPI tests, using the largest values required for all It() tests in this CAPI test.
48-
requiredResources = &shared.TestResource{EC2Normal: 4 * e2eCtx.Settings.InstanceVCPU, IGW: 1, NGW: 3, VPC: 1, ClassicLB: 1, EIP: 3}
48+
requiredResources = &shared.TestResource{EC2Normal: 4 * e2eCtx.Settings.InstanceVCPU, IGW: 1, NGW: 3, VPC: 1, ClassicLB: 1, EIP: 3, EventBridgeRules: 50}
4949
requiredResources.WriteRequestedResources(e2eCtx, "capi-remediation-test")
5050
Expect(shared.AcquireResources(requiredResources, ginkgo.GinkgoParallelProcess(), flock.New(shared.ResourceQuotaFilePath))).To(Succeed())
5151
})
@@ -67,7 +67,7 @@ var _ = ginkgo.Context("[unmanaged] [Cluster API Framework]", func() {
6767
ginkgo.Describe("Machine Pool Spec", func() {
6868
ginkgo.BeforeEach(func() {
6969
// As the resources cannot be defined by the It() clause in CAPI tests, using the largest values required for all It() tests in this CAPI test.
70-
requiredResources = &shared.TestResource{EC2Normal: 4 * e2eCtx.Settings.InstanceVCPU, IGW: 1, NGW: 1, VPC: 1, ClassicLB: 1, EIP: 3}
70+
requiredResources = &shared.TestResource{EC2Normal: 4 * e2eCtx.Settings.InstanceVCPU, IGW: 1, NGW: 1, VPC: 1, ClassicLB: 1, EIP: 3, EventBridgeRules: 50}
7171
requiredResources.WriteRequestedResources(e2eCtx, "capi-machinepool-test")
7272
Expect(shared.AcquireResources(requiredResources, ginkgo.GinkgoParallelProcess(), flock.New(shared.ResourceQuotaFilePath))).To(Succeed())
7373
})
@@ -89,7 +89,7 @@ var _ = ginkgo.Context("[unmanaged] [Cluster API Framework]", func() {
8989
ginkgo.Describe("Self Hosted Spec", func() {
9090
ginkgo.BeforeEach(func() {
9191
// As the resources cannot be defined by the It() clause in CAPI tests, using the largest values required for all It() tests in this CAPI test.
92-
requiredResources = &shared.TestResource{EC2Normal: 2 * e2eCtx.Settings.InstanceVCPU, IGW: 1, NGW: 1, VPC: 1, ClassicLB: 1, EIP: 1}
92+
requiredResources = &shared.TestResource{EC2Normal: 2 * e2eCtx.Settings.InstanceVCPU, IGW: 1, NGW: 1, VPC: 1, ClassicLB: 1, EIP: 1, EventBridgeRules: 50}
9393
requiredResources.WriteRequestedResources(e2eCtx, "capi-clusterctl-self-hosted-test")
9494
Expect(shared.AcquireResources(requiredResources, ginkgo.GinkgoParallelProcess(), flock.New(shared.ResourceQuotaFilePath))).To(Succeed())
9595
})
@@ -112,7 +112,7 @@ var _ = ginkgo.Context("[unmanaged] [Cluster API Framework]", func() {
112112
ginkgo.Describe("Clusterctl Upgrade Spec [from latest v1beta1 release to v1beta2]", func() {
113113
ginkgo.BeforeEach(func() {
114114
// As the resources cannot be defined by the It() clause in CAPI tests, using the largest values required for all It() tests in this CAPI test.
115-
requiredResources = &shared.TestResource{EC2Normal: 5 * e2eCtx.Settings.InstanceVCPU, IGW: 2, NGW: 2, VPC: 2, ClassicLB: 2, EIP: 2}
115+
requiredResources = &shared.TestResource{EC2Normal: 5 * e2eCtx.Settings.InstanceVCPU, IGW: 2, NGW: 2, VPC: 2, ClassicLB: 2, EIP: 2, EventBridgeRules: 50}
116116
requiredResources.WriteRequestedResources(e2eCtx, "capi-clusterctl-upgrade-test-v1beta1-to-v1beta2")
117117
Expect(shared.AcquireResources(requiredResources, ginkgo.GinkgoParallelProcess(), flock.New(shared.ResourceQuotaFilePath))).To(Succeed())
118118
})
@@ -137,7 +137,7 @@ var _ = ginkgo.Context("[unmanaged] [Cluster API Framework]", func() {
137137
ginkgo.Describe("Cluster Upgrade Spec - Single control plane with workers [K8s-Upgrade]", func() {
138138
ginkgo.BeforeEach(func() {
139139
// As the resources cannot be defined by the It() clause in CAPI tests, using the largest values required for all It() tests in this CAPI test.
140-
requiredResources = &shared.TestResource{EC2Normal: 5 * e2eCtx.Settings.InstanceVCPU, IGW: 2, NGW: 2, VPC: 2, ClassicLB: 2, EIP: 2}
140+
requiredResources = &shared.TestResource{EC2Normal: 5 * e2eCtx.Settings.InstanceVCPU, IGW: 2, NGW: 2, VPC: 2, ClassicLB: 2, EIP: 2, EventBridgeRules: 50}
141141
requiredResources.WriteRequestedResources(e2eCtx, "capi-worker-upgrade-test")
142142
Expect(shared.AcquireResources(requiredResources, ginkgo.GinkgoParallelProcess(), flock.New(shared.ResourceQuotaFilePath))).To(Succeed())
143143
})
@@ -162,7 +162,7 @@ var _ = ginkgo.Context("[unmanaged] [Cluster API Framework]", func() {
162162
ginkgo.Describe("Cluster Upgrade Spec - HA control plane with scale in rollout [K8s-Upgrade]", func() {
163163
ginkgo.BeforeEach(func() {
164164
// As the resources cannot be defined by the It() clause in CAPI tests, using the largest values required for all It() tests in this CAPI test.
165-
requiredResources = &shared.TestResource{EC2Normal: 10 * e2eCtx.Settings.InstanceVCPU, IGW: 2, NGW: 2, VPC: 2, ClassicLB: 2, EIP: 2}
165+
requiredResources = &shared.TestResource{EC2Normal: 10 * e2eCtx.Settings.InstanceVCPU, IGW: 2, NGW: 2, VPC: 2, ClassicLB: 2, EIP: 2, EventBridgeRules: 50}
166166
requiredResources.WriteRequestedResources(e2eCtx, "capi-ha-cluster-upgrade-scale-in-test")
167167
Expect(shared.AcquireResources(requiredResources, ginkgo.GinkgoParallelProcess(), flock.New(shared.ResourceQuotaFilePath))).To(Succeed())
168168
})
@@ -185,7 +185,7 @@ var _ = ginkgo.Context("[unmanaged] [Cluster API Framework]", func() {
185185
ginkgo.Describe("Cluster Upgrade Spec - HA Control Plane Cluster [K8s-Upgrade]", func() {
186186
ginkgo.BeforeEach(func() {
187187
// As the resources cannot be defined by the It() clause in CAPI tests, using the largest values required for all It() tests in this CAPI test.
188-
requiredResources = &shared.TestResource{EC2Normal: 10 * e2eCtx.Settings.InstanceVCPU, IGW: 2, NGW: 2, VPC: 2, ClassicLB: 2, EIP: 2}
188+
requiredResources = &shared.TestResource{EC2Normal: 10 * e2eCtx.Settings.InstanceVCPU, IGW: 2, NGW: 2, VPC: 2, ClassicLB: 2, EIP: 2, EventBridgeRules: 50}
189189
requiredResources.WriteRequestedResources(e2eCtx, "capi-ha-cluster-upgrade-test")
190190
Expect(shared.AcquireResources(requiredResources, ginkgo.GinkgoParallelProcess(), flock.New(shared.ResourceQuotaFilePath))).To(Succeed())
191191
})

‎test/e2e/suites/unmanaged/unmanaged_functional_clusterclass_test.go

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -53,7 +53,7 @@ var _ = ginkgo.Context("[unmanaged] [functional] [ClusterClass]", func() {
5353
ginkgo.It("should create cluster with nested assumed role", func() {
5454
// Setup a Namespace where to host objects for this spec and create a watcher for the namespace events.
5555
specName := "functional-multitenancy-nested-clusterclass"
56-
requiredResources = &shared.TestResource{EC2Normal: 1 * e2eCtx.Settings.InstanceVCPU, IGW: 1, NGW: 1, VPC: 1, ClassicLB: 1, EIP: 1}
56+
requiredResources = &shared.TestResource{EC2Normal: 1 * e2eCtx.Settings.InstanceVCPU, IGW: 1, NGW: 1, VPC: 1, ClassicLB: 1, EIP: 1, EventBridgeRules: 50}
5757
requiredResources.WriteRequestedResources(e2eCtx, specName)
5858
Expect(shared.AcquireResources(requiredResources, ginkgo.GinkgoParallelProcess(), flock.New(shared.ResourceQuotaFilePath))).To(Succeed())
5959
defer shared.ReleaseResources(requiredResources, ginkgo.GinkgoParallelProcess(), flock.New(shared.ResourceQuotaFilePath))
@@ -94,7 +94,7 @@ var _ = ginkgo.Context("[unmanaged] [functional] [ClusterClass]", func() {
9494
ginkgo.Describe("Workload cluster with AWS SSM Parameter as the Secret Backend [ClusterClass]", func() {
9595
ginkgo.It("should be creatable and deletable", func() {
9696
specName := "functional-test-ssm-parameter-store-clusterclass"
97-
requiredResources = &shared.TestResource{EC2Normal: 2 * e2eCtx.Settings.InstanceVCPU, IGW: 1, NGW: 1, VPC: 1, ClassicLB: 1, EIP: 3}
97+
requiredResources = &shared.TestResource{EC2Normal: 2 * e2eCtx.Settings.InstanceVCPU, IGW: 1, NGW: 1, VPC: 1, ClassicLB: 1, EIP: 3, EventBridgeRules: 50}
9898
requiredResources.WriteRequestedResources(e2eCtx, specName)
9999
Expect(shared.AcquireResources(requiredResources, ginkgo.GinkgoParallelProcess(), flock.New(shared.ResourceQuotaFilePath))).To(Succeed())
100100
defer shared.ReleaseResources(requiredResources, ginkgo.GinkgoParallelProcess(), flock.New(shared.ResourceQuotaFilePath))
@@ -136,7 +136,7 @@ var _ = ginkgo.Context("[unmanaged] [functional] [ClusterClass]", func() {
136136

137137
// Some infrastructure creation was moved to a setup node to better organize the test.
138138
ginkgo.JustBeforeEach(func() {
139-
requiredResources = &shared.TestResource{EC2Normal: 2 * e2eCtx.Settings.InstanceVCPU, IGW: 2, NGW: 2, VPC: 2, ClassicLB: 2, EIP: 5}
139+
requiredResources = &shared.TestResource{EC2Normal: 2 * e2eCtx.Settings.InstanceVCPU, IGW: 2, NGW: 2, VPC: 2, ClassicLB: 2, EIP: 5, EventBridgeRules: 50}
140140
requiredResources.WriteRequestedResources(e2eCtx, specName)
141141
Expect(shared.AcquireResources(requiredResources, ginkgo.GinkgoParallelProcess(), flock.New(shared.ResourceQuotaFilePath))).To(Succeed())
142142
namespace = shared.SetupSpecNamespace(ctx, specName, e2eCtx)

0 commit comments

Comments
 (0)