Remove unnecessary select in pod runner (#5436)

kanisterio · Apr 22, 2019 · e928b88 · e928b88
1 parent 2339a30
commit e928b88
Showing 1 changed file with 4 additions and 6 deletions.
diff --git a/pkg/kube/pod_runner.go b/pkg/kube/pod_runner.go
@@ -35,12 +35,10 @@ func (p *PodRunner) Run(ctx context.Context, fn func(context.Context, *v1.Pod) (
 		return nil, errors.Wrapf(err, "Failed to create pod")
 	}
 	go func() {
-		select {
-		case <-ctx.Done():
-			err := DeletePod(context.Background(), p.cli, pod)
-			if err != nil {
-				log.Error("Failed to delete pod ", err.Error())
-			}
+		<-ctx.Done()
+		err := DeletePod(context.Background(), p.cli, pod)
+		if err != nil {
+			log.Error("Failed to delete pod ", err.Error())
 		}
 	}()
 	return fn(ctx, pod)