@@ -19,17 +19,18 @@ package e2enode
19
19
import (
20
20
"context"
21
21
"fmt"
22
- "k8s.io/kubernetes/pkg/apis/core/v1/helper/qos"
23
- "k8s.io/kubernetes/pkg/kubelet/apis/config"
24
- e2eskipper "k8s.io/kubernetes/test/e2e/framework/skipper"
25
- "k8s.io/kubernetes/test/e2e/nodefeature"
26
- imageutils "k8s.io/kubernetes/test/utils/image"
27
22
"math/big"
28
23
"path/filepath"
29
24
"strconv"
30
25
"strings"
31
26
"time"
32
27
28
+ "k8s.io/kubernetes/pkg/apis/core/v1/helper/qos"
29
+ "k8s.io/kubernetes/pkg/kubelet/apis/config"
30
+ e2eskipper "k8s.io/kubernetes/test/e2e/framework/skipper"
31
+ "k8s.io/kubernetes/test/e2e/nodefeature"
32
+ imageutils "k8s.io/kubernetes/test/utils/image"
33
+
33
34
"github.com/onsi/ginkgo/v2"
34
35
"github.com/onsi/gomega"
35
36
v1 "k8s.io/api/core/v1"
@@ -70,7 +71,9 @@ var _ = SIGDescribe("Swap", "[LinuxOnly]", nodefeature.Swap, func() {
70
71
pod := getSwapTestPod (f , qosClass , memoryRequestEqualLimit )
71
72
pod = runPodAndWaitUntilScheduled (f , pod )
72
73
73
- gomega .Expect (isPodCgroupV2 (f , pod )).To (gomega .BeTrueBecause ("cgroup v2 is required for swap" ))
74
+ if ! isPodCgroupV2 (f , pod ) {
75
+ e2eskipper .Skipf ("swap tests require cgroup v2" )
76
+ }
74
77
gomega .Expect (getSwapBehavior ()).To (gomega .Or (gomega .Equal (types .NoSwap ), gomega .BeEmpty ()), "NodeConformance is expected to run with NoSwap" )
75
78
76
79
expectNoSwap (f , pod )
@@ -103,7 +106,9 @@ var _ = SIGDescribe("Swap", "[LinuxOnly]", nodefeature.Swap, func() {
103
106
pod := getSwapTestPod (f , qosClass , memoryRequestEqualLimit )
104
107
pod = runPodAndWaitUntilScheduled (f , pod )
105
108
106
- gomega .Expect (isPodCgroupV2 (f , pod )).To (gomega .BeTrueBecause ("cgroup v2 is required for swap" ))
109
+ if ! isPodCgroupV2 (f , pod ) {
110
+ e2eskipper .Skipf ("swap tests require cgroup v2" )
111
+ }
107
112
gomega .Expect (getSwapBehavior ()).To (gomega .Equal (types .LimitedSwap ))
108
113
109
114
expectedSwapLimit := calcSwapForBurstablePod (f , pod )
@@ -136,7 +141,9 @@ var _ = SIGDescribe("Swap", "[LinuxOnly]", nodefeature.Swap, func() {
136
141
137
142
sleepingPod := getSleepingPod (f .Namespace .Name )
138
143
sleepingPod = runPodAndWaitUntilScheduled (f , sleepingPod )
139
- gomega .Expect (isPodCgroupV2 (f , sleepingPod )).To (gomega .BeTrueBecause ("node uses cgroup v1" ))
144
+ if ! isPodCgroupV2 (f , sleepingPod ) {
145
+ e2eskipper .Skipf ("swap tests require cgroup v2" )
146
+ }
140
147
141
148
nodeName = sleepingPod .Spec .NodeName
142
149
gomega .Expect (nodeName ).ToNot (gomega .BeEmpty (), "node name is empty" )
0 commit comments