@@ -26,7 +26,9 @@ import (
26
26
27
27
v1 "k8s.io/api/core/v1"
28
28
kubeletdevicepluginv1beta1 "k8s.io/kubelet/pkg/apis/deviceplugin/v1beta1"
29
+ "k8s.io/kubernetes/pkg/features"
29
30
e2epod "k8s.io/kubernetes/test/e2e/framework/pod"
31
+ e2eskipper "k8s.io/kubernetes/test/e2e/framework/skipper"
30
32
"k8s.io/kubernetes/test/e2e/nodefeature"
31
33
imageutils "k8s.io/kubernetes/test/utils/image"
32
34
admissionapi "k8s.io/pod-security-admission/api"
@@ -123,6 +125,8 @@ var _ = SIGDescribe("Device Plugin Failures Pod Status", nodefeature.ResourceHea
123
125
devicePluginUpdateTimeout := 1 * time .Minute
124
126
125
127
ginkgo .It ("will report a Healthy and then Unhealthy single device in the pod status" , func (ctx context.Context ) {
128
+ e2eskipper .SkipUnlessFeatureGateEnabled (features .ResourceHealthStatus )
129
+
126
130
// randomizing so tests can run in parallel
127
131
resourceName := fmt .Sprintf ("test.device/%s" , f .UniqueName )
128
132
devices := []kubeletdevicepluginv1beta1.Device {{ID : "testdevice" , Health : kubeletdevicepluginv1beta1 .Healthy }}
@@ -181,6 +185,8 @@ var _ = SIGDescribe("Device Plugin Failures Pod Status", nodefeature.ResourceHea
181
185
})
182
186
183
187
ginkgo .It ("will report a Device Status for the failed pod in the pod status" , func (ctx context.Context ) {
188
+ e2eskipper .SkipUnlessFeatureGateEnabled (features .ResourceHealthStatus )
189
+
184
190
// randomizing so tests can run in parallel
185
191
resourceName := fmt .Sprintf ("test.device/%s" , f .UniqueName )
186
192
devices := []kubeletdevicepluginv1beta1.Device {{ID : "testdevice" , Health : kubeletdevicepluginv1beta1 .Healthy }}
0 commit comments