github/kubernetes
1
0
Fork 0
mirror of https://github.com/k3s-io/kubernetes.git synced 2025-08-11 21:12:07 +00:00
Code Issues Projects Releases Wiki Activity

Patch all nodes with extended resource to allow testing on every node

Browse Source 
Signed-off-by: Itamar Holder <iholder@redhat.com>
This commit is contained in:
Itamar Holder 2024-05-05 09:54:36 +03:00
parent f43f5bc821
commit 85068bce13
1 changed files with 8 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

17
test/e2e/node/pod_resize.go
View File

@ -1402,7 +1402,6 @@ func doPodResizeTests() {
ginkgo.It(tc.name, func(ctx context.Context) { ginkgo.It(tc.name, func(ctx context.Context) {
var testPod, patchedPod *v1.Pod var testPod, patchedPod *v1.Pod
var pErr error var pErr error
var nodeName string
tStamp := strconv.Itoa(time.Now().Nanosecond()) tStamp := strconv.Itoa(time.Now().Nanosecond())
initDefaultResizePolicy(tc.containers) initDefaultResizePolicy(tc.containers)
@ -1413,10 +1412,14 @@ func doPodResizeTests() {
nodes, err := e2enode.GetReadySchedulableNodes(context.Background(), f.ClientSet) nodes, err := e2enode.GetReadySchedulableNodes(context.Background(), f.ClientSet)
framework.ExpectNoError(err) framework.ExpectNoError(err)
nodeName = nodes.Items[0].Name for _, node := range nodes.Items {
addExtendedResource(f.ClientSet, node.Name, fakeExtendedResource, resource.MustParse("123"))
addExtendedResource(f.ClientSet, nodeName, fakeExtendedResource, resource.MustParse("123")) }
testPod.Spec.NodeName = nodeName defer func() {
for _, node := range nodes.Items {
removeExtendedResource(f.ClientSet, node.Name, fakeExtendedResource)
}
}()
} }
ginkgo.By("creating pod") ginkgo.By("creating pod")
@ -1480,10 +1483,6 @@ func doPodResizeTests() {
ginkgo.By("deleting pod") ginkgo.By("deleting pod")
err = e2epod.DeletePodWithWait(ctx, f.ClientSet, newPod) err = e2epod.DeletePodWithWait(ctx, f.ClientSet, newPod)
framework.ExpectNoError(err, "failed to delete pod") framework.ExpectNoError(err, "failed to delete pod")
if tc.addExtendedResource {
removeExtendedResource(f.ClientSet, nodeName, fakeExtendedResource)
}
}) })
} }
} }