@@ -53,7 +53,6 @@ import (
53
53
imageutils "k8s.io/kubernetes/test/utils/image"
54
54
55
55
"github.com/onsi/ginkgo"
56
- "github.com/onsi/gomega"
57
56
)
58
57
59
58
const (
@@ -122,7 +121,7 @@ var _ = SIGDescribe("Cluster size autoscaling [Slow]", func() {
122
121
coreCount += quantity .Value ()
123
122
}
124
123
ginkgo .By (fmt .Sprintf ("Initial number of schedulable nodes: %v" , nodeCount ))
125
- gomega . Expect (nodeCount ). NotTo ( gomega . BeZero () )
124
+ framework . ExpectNotEqual (nodeCount , 0 )
126
125
mem := nodes .Items [0 ].Status .Allocatable [v1 .ResourceMemory ]
127
126
memAllocatableMb = int ((& mem ).Value () / 1024 / 1024 )
128
127
@@ -856,7 +855,7 @@ var _ = SIGDescribe("Cluster size autoscaling [Slow]", func() {
856
855
framework .ExpectNoError (e2enode .WaitForReadyNodes (c , nodeCount - minSize + 1 , resizeTimeout ))
857
856
ngNodes , err := framework .GetGroupNodes (minMig )
858
857
framework .ExpectNoError (err )
859
- gomega . Expect (len (ngNodes ) == 1 ). To ( gomega . BeTrue () )
858
+ framework . ExpectEqual (len (ngNodes ) == 1 , true )
860
859
node , err := f .ClientSet .CoreV1 ().Nodes ().Get (ngNodes [0 ], metav1.GetOptions {})
861
860
ginkgo .By (fmt .Sprintf ("Target node for scale-down: %s" , node .Name ))
862
861
framework .ExpectNoError (err )
@@ -909,7 +908,7 @@ var _ = SIGDescribe("Cluster size autoscaling [Slow]", func() {
909
908
"spec.unschedulable" : "false" ,
910
909
}.AsSelector ().String ()})
911
910
framework .ExpectNoError (err )
912
- gomega . Expect (nodesToBreakCount <= len (nodes .Items )). To ( gomega . BeTrue () )
911
+ framework . ExpectEqual (nodesToBreakCount <= len (nodes .Items ), true )
913
912
nodesToBreak := nodes .Items [:nodesToBreakCount ]
914
913
915
914
// TestUnderTemporaryNetworkFailure only removes connectivity to a single node,
0 commit comments