@@ -30,6 +30,7 @@ import (
30
30
"k8s.io/kubernetes/test/e2e/framework"
31
31
e2ekubelet "k8s.io/kubernetes/test/e2e/framework/kubelet"
32
32
e2enode "k8s.io/kubernetes/test/e2e/framework/node"
33
+ e2eskipper "k8s.io/kubernetes/test/e2e/framework/skipper"
33
34
e2essh "k8s.io/kubernetes/test/e2e/framework/ssh"
34
35
testutils "k8s.io/kubernetes/test/utils"
35
36
@@ -47,15 +48,15 @@ var _ = SIGDescribe("NodeProblemDetector [DisabledForLargeClusters]", func() {
47
48
f := framework .NewDefaultFramework ("node-problem-detector" )
48
49
49
50
ginkgo .BeforeEach (func () {
50
- framework .SkipUnlessSSHKeyPresent ()
51
- framework .SkipUnlessProviderIs (framework .ProvidersWithSSH ... )
52
- framework .SkipUnlessProviderIs ("gce" , "gke" )
53
- framework .SkipUnlessNodeOSDistroIs ("gci" , "ubuntu" )
51
+ e2eskipper .SkipUnlessSSHKeyPresent ()
52
+ e2eskipper .SkipUnlessProviderIs (framework .ProvidersWithSSH ... )
53
+ e2eskipper .SkipUnlessProviderIs ("gce" , "gke" )
54
+ e2eskipper .SkipUnlessNodeOSDistroIs ("gci" , "ubuntu" )
54
55
e2enode .WaitForTotalHealthy (f .ClientSet , time .Minute )
55
56
})
56
57
57
58
ginkgo .It ("should run without error" , func () {
58
- framework .SkipUnlessSSHKeyPresent ()
59
+ e2eskipper .SkipUnlessSSHKeyPresent ()
59
60
60
61
ginkgo .By ("Getting all nodes and their SSH-able IP addresses" )
61
62
nodes , err := e2enode .GetReadySchedulableNodes (f .ClientSet )
0 commit comments