File tree Expand file tree Collapse file tree 2 files changed +2
-3
lines changed Expand file tree Collapse file tree 2 files changed +2
-3
lines changed Original file line number Diff line number Diff line change @@ -12,7 +12,6 @@ go_library(
12
12
importpath = "k8s.io/kubernetes/test/e2e/framework/pod" ,
13
13
visibility = ["//visibility:public" ],
14
14
deps = [
15
- "//pkg/kubelet/types:go_default_library" ,
16
15
"//staging/src/k8s.io/api/core/v1:go_default_library" ,
17
16
"//staging/src/k8s.io/apimachinery/pkg/api/errors:go_default_library" ,
18
17
"//staging/src/k8s.io/apimachinery/pkg/apis/meta/v1:go_default_library" ,
Original file line number Diff line number Diff line change @@ -34,7 +34,6 @@ import (
34
34
clientset "k8s.io/client-go/kubernetes"
35
35
"k8s.io/klog"
36
36
"k8s.io/kubectl/pkg/util/podutils"
37
- kubetypes "k8s.io/kubernetes/pkg/kubelet/types"
38
37
e2elog "k8s.io/kubernetes/test/e2e/framework/log"
39
38
testutils "k8s.io/kubernetes/test/utils"
40
39
imageutils "k8s.io/kubernetes/test/utils/image"
@@ -380,7 +379,8 @@ func FilterNonRestartablePods(pods []*v1.Pod) []*v1.Pod {
380
379
}
381
380
382
381
func isNotRestartAlwaysMirrorPod (p * v1.Pod ) bool {
383
- if ! kubetypes .IsMirrorPod (p ) {
382
+ // Check if the pod is a mirror pod
383
+ if _ , ok := p .Annotations [v1 .MirrorPodAnnotationKey ]; ! ok {
384
384
return false
385
385
}
386
386
return p .Spec .RestartPolicy != v1 .RestartPolicyAlways
You can’t perform that action at this time.
0 commit comments