github/kubernetes
1
0
Fork 0
mirror of https://github.com/k3s-io/kubernetes.git synced 2025-07-25 20:53:33 +00:00
Code Issues Projects Releases Wiki Activity

Merge pull request #89379 from derekwaynecarr/increase-graceperiod-timeout

Browse Source 
deflake grace period for pod deletion in node e2e
This commit is contained in:
Kubernetes Prow Robot 2020-03-24 15:27:44 -07:00 committed by GitHub
commit dfe83809f3
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 6 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
test/e2e/node/pods.go
View File

@ -55,9 +55,9 @@ var _ = SIGDescribe("Pods Extended", func() {
/* /*
Release : v1.15 Release : v1.15
Testname: Pods, delete grace period Testname: Pods, delete grace period
Description: Create a pod, make sure it is running. Using the http client send a 'delete' with gracePeriodSeconds=30. Pod SHOULD get deleted within 30 seconds. Description: Create a pod, make sure it is running. Using the http client send a 'delete' with gracePeriodSeconds=30. Pod SHOULD get terminated within gracePeriodSeconds and removed from API server within a window.
*/ */
ginkgo.It("should be submitted and removed [Flaky]", func() { ginkgo.It("should be submitted and removed", func() {
ginkgo.By("creating the pod") ginkgo.By("creating the pod")
name := "pod-submit-remove-" + string(uuid.NewUUID()) name := "pod-submit-remove-" + string(uuid.NewUUID())
value := strconv.Itoa(time.Now().Nanosecond()) value := strconv.Itoa(time.Now().Nanosecond())
@ -117,8 +117,11 @@ var _ = SIGDescribe("Pods Extended", func() {
ginkgo.By("verifying the kubelet observed the termination notice") ginkgo.By("verifying the kubelet observed the termination notice")
// allow up to 3x grace period (which allows process termination)
// for the kubelet to remove from api. need to follow-up on if this
// latency between termination and reportal can be isolated further.
start := time.Now() start := time.Now()
err = wait.Poll(time.Second*5, time.Second*30, func() (bool, error) { err = wait.Poll(time.Second*5, time.Second*30*3, func() (bool, error) {
podList, err := e2ekubelet.GetKubeletPods(f.ClientSet, pod.Spec.NodeName) podList, err := e2ekubelet.GetKubeletPods(f.ClientSet, pod.Spec.NodeName)
if err != nil { if err != nil {
framework.Logf("Unable to retrieve kubelet pods for node %v: %v", pod.Spec.NodeName, err) framework.Logf("Unable to retrieve kubelet pods for node %v: %v", pod.Spec.NodeName, err)