github/kubernetes
1
0
Fork 0
mirror of https://github.com/k3s-io/kubernetes.git synced 2025-08-02 08:17:26 +00:00
Code Issues Projects Releases Wiki Activity

Handles clean up errors

Browse Source
This commit is contained in:
Mahmoud Atwa 2024-01-16 11:53:55 +00:00
parent 80fbc4c319
commit ec89154276
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
test/e2e/autoscaling/cluster_size_autoscaling.go
View File

@ -1008,7 +1008,7 @@ var _ = SIGDescribe("Cluster size autoscaling", framework.WithSlow(), func() {
replicaCount := 2 * nodeCount replicaCount := 2 * nodeCount
reservedMemory := int(float64(replicaCount) * float64(0.7) * float64(memAllocatableMb)) reservedMemory := int(float64(replicaCount) * float64(0.7) * float64(memAllocatableMb))
cleanupFunc := ReserveMemoryWithSchedulerName(ctx, f, "memory-reservation", replicaCount, reservedMemory, false, 1, nonExistingBypassedSchedulerName) cleanupFunc := ReserveMemoryWithSchedulerName(ctx, f, "memory-reservation", replicaCount, reservedMemory, false, 1, nonExistingBypassedSchedulerName)
defer cleanupFunc() defer framework.ExpectNoError(cleanupFunc())
// Verify that cluster size is increased // Verify that cluster size is increased
ginkgo.By("Waiting for cluster scale-up") ginkgo.By("Waiting for cluster scale-up")
sizeFunc := func(size int) bool { sizeFunc := func(size int) bool {
@ -1022,7 +1022,7 @@ var _ = SIGDescribe("Cluster size autoscaling", framework.WithSlow(), func() {
replicaCount := 1 replicaCount := 1
reservedMemory := int(float64(0.5) * float64(memAllocatableMb)) reservedMemory := int(float64(0.5) * float64(memAllocatableMb))
cleanupFunc := ReserveMemoryWithSchedulerName(ctx, f, "memory-reservation", replicaCount, reservedMemory, false, 1, nonExistingBypassedSchedulerName) cleanupFunc := ReserveMemoryWithSchedulerName(ctx, f, "memory-reservation", replicaCount, reservedMemory, false, 1, nonExistingBypassedSchedulerName)
defer cleanupFunc() defer framework.ExpectNoError(cleanupFunc())
// Verify that cluster size is the same // Verify that cluster size is the same
ginkgo.By(fmt.Sprintf("Waiting for scale up hoping it won't happen, polling cluster size for %s", scaleUpTimeout.String())) ginkgo.By(fmt.Sprintf("Waiting for scale up hoping it won't happen, polling cluster size for %s", scaleUpTimeout.String()))
sizeFunc := func(size int) bool { sizeFunc := func(size int) bool {
@ -1038,7 +1038,7 @@ var _ = SIGDescribe("Cluster size autoscaling", framework.WithSlow(), func() {
reservedMemory := int(float64(replicaCount) * float64(0.7) * float64(memAllocatableMb)) reservedMemory := int(float64(replicaCount) * float64(0.7) * float64(memAllocatableMb))
schedulerName := "non-existent-scheduler-" + f.UniqueName schedulerName := "non-existent-scheduler-" + f.UniqueName
cleanupFunc := ReserveMemoryWithSchedulerName(ctx, f, "memory-reservation", replicaCount, reservedMemory, false, 1, schedulerName) cleanupFunc := ReserveMemoryWithSchedulerName(ctx, f, "memory-reservation", replicaCount, reservedMemory, false, 1, schedulerName)
defer cleanupFunc() defer framework.ExpectNoError(cleanupFunc())
// Verify that cluster size is the same // Verify that cluster size is the same
ginkgo.By(fmt.Sprintf("Waiting for scale up hoping it won't happen, polling cluster size for %s", scaleUpTimeout.String())) ginkgo.By(fmt.Sprintf("Waiting for scale up hoping it won't happen, polling cluster size for %s", scaleUpTimeout.String()))
sizeFunc := func(size int) bool { sizeFunc := func(size int) bool {