github/kubernetes
1
0
Fork 0
mirror of https://github.com/k3s-io/kubernetes.git synced 2026-07-18 13:57:38 +00:00
Code Issues Projects Releases Wiki Activity

Merge pull request #137561 from bart0sh/PR225-DRA-fix-ExtendedResource-upgrade-downgrade-flakes

Browse Source 
test/e2e_dra: retry pod check during upgrade/downgrade
This commit is contained in:
Kubernetes Prow Robot
2026-03-09 21:57:15 +05:30
committed by GitHub
parent e026a9482a aa731ab5c0
commit 4a300f8e6d
1 changed files with 8 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

9
test/e2e_dra/extendedresources_test.go
View File

@@ -28,6 +28,7 @@ import (
"k8s.io/apimachinery/pkg/api/resource"
metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
drautils "k8s.io/kubernetes/test/e2e/dra/utils"
"k8s.io/kubernetes/test/e2e/framework"
e2epod "k8s.io/kubernetes/test/e2e/framework/pod"
"k8s.io/kubernetes/test/utils/ktesting"
)
@@ -158,7 +159,13 @@ func createPodWithExtendedResource(tCtx ktesting.TContext, b *drautils.Builder,
// verifyPodRunningWithClaim verifies a pod is running and has a valid ResourceClaim.
func verifyPodRunningWithClaim(tCtx ktesting.TContext, b *drautils.Builder, pod *v1.Pod, resourceName v1.ResourceName) {
namespace := tCtx.Namespace()
b.TestPod(tCtx, pod, "container_0_request_0", "true")
// Use Eventually to retry the full run+exec check. During cluster upgrades and
// downgrades, nodes are temporarily restarted, which can cause transient exec
// failures ("unable to upgrade connection: pod does not exist") even though the
// pod is reported as Running by the API server.
tCtx.Eventually(func(tCtx ktesting.TContext) {
b.TestPod(tCtx, pod, "container_0_request_0", "true")
}).WithTimeout(framework.PodStartTimeout).Should(gomega.Succeed(), "pod %s should be running with expected env", pod.Name)
tCtx.Logf("Pod %q is running", pod.Name)
// Get updated pod to check status