github/kubernetes
1
0
Fork 0
mirror of https://github.com/k3s-io/kubernetes.git synced 2025-07-19 18:02:01 +00:00
Code Issues Projects Releases Wiki Activity

Deflake LimitRange e2e test

Browse Source
This commit is contained in:
Wei Huang 2020-08-07 17:22:35 -07:00
parent a640545167
commit 24bbedb27d
No known key found for this signature in database
GPG Key ID: BE5E9752F8B6E005
1 changed files with 7 additions and 15 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

22
test/e2e/scheduling/limit_range.go
View File

@ -38,7 +38,6 @@ import (
imageutils "k8s.io/kubernetes/test/utils/image"
"github.com/onsi/ginkgo"
"github.com/onsi/gomega"
)
const (
@ -206,10 +205,8 @@ var _ = SIGDescribe("LimitRange", func() {
framework.ExpectNoError(err)
ginkgo.By("Verifying the LimitRange was deleted")
gomega.Expect(wait.Poll(time.Second*5, e2eservice.RespondingTimeout, func() (bool, error) {
selector := labels.SelectorFromSet(labels.Set(map[string]string{"name": limitRange.Name}))
options := metav1.ListOptions{LabelSelector: selector.String()}
limitRanges, err := f.ClientSet.CoreV1().LimitRanges(f.Namespace.Name).List(context.TODO(), options)
err = wait.Poll(time.Second*5, e2eservice.RespondingTimeout, func() (bool, error) {
limitRanges, err := f.ClientSet.CoreV1().LimitRanges(f.Namespace.Name).List(context.TODO(), metav1.ListOptions{})
if err != nil {
framework.Logf("Unable to retrieve LimitRanges: %v", err)
@ -221,19 +218,14 @@ var _ = SIGDescribe("LimitRange", func() {
return true, nil
}
if len(limitRanges.Items) > 0 {
if limitRanges.Items[0].ObjectMeta.DeletionTimestamp == nil {
framework.Logf("deletion has not yet been observed")
return false, nil
}
return true, nil
for i := range limitRanges.Items {
lr := limitRanges.Items[i]
framework.Logf("LimitRange %v/%v has not yet been deleted", lr.Namespace, lr.Name)
}
return false, nil
}))
framework.ExpectNoError(err, "kubelet never observed the termination notice")
})
framework.ExpectNoError(err)
ginkgo.By("Creating a Pod with more than former max resources")
pod = newTestPod(podName+"2", getResourceList("600m", "600Mi", "600Gi"), v1.ResourceList{})