@@ -194,6 +194,14 @@ var _ = SIGDescribe("SchedulerPreemption [Serial]", func() {
194
194
195
195
ginkgo .By ("Run a critical pod that use 60% of a node resources." )
196
196
// Create a critical pod and make sure it is scheduled.
197
+ defer func () {
198
+ // Clean-up the critical pod
199
+ // Always run cleanup to make sure the pod is properly cleaned up.
200
+ err := f .ClientSet .CoreV1 ().Pods (metav1 .NamespaceSystem ).Delete ("critical-pod" , metav1 .NewDeleteOptions (0 ))
201
+ if err != nil && ! errors .IsNotFound (err ) {
202
+ framework .Failf ("Error cleanup pod `%s/%s`: %v" , metav1 .NamespaceSystem , "critical-pod" , err )
203
+ }
204
+ }()
197
205
runPausePod (f , pausePodConfig {
198
206
Name : "critical-pod" ,
199
207
Namespace : metav1 .NamespaceSystem ,
@@ -204,11 +212,6 @@ var _ = SIGDescribe("SchedulerPreemption [Serial]", func() {
204
212
})
205
213
// Make sure that the lowest priority pod is deleted.
206
214
preemptedPod , err := cs .CoreV1 ().Pods (pods [0 ].Namespace ).Get (pods [0 ].Name , metav1.GetOptions {})
207
- defer func () {
208
- // Clean-up the critical pod
209
- err := f .ClientSet .CoreV1 ().Pods (metav1 .NamespaceSystem ).Delete ("critical-pod" , metav1 .NewDeleteOptions (0 ))
210
- framework .ExpectNoError (err )
211
- }()
212
215
podDeleted := (err != nil && errors .IsNotFound (err )) ||
213
216
(err == nil && preemptedPod .DeletionTimestamp != nil )
214
217
gomega .Expect (podDeleted ).To (gomega .BeTrue ())
0 commit comments