Add timeout for version exec

vmware-archive · Sep 13, 2021 · 11ec9d4 · 11ec9d4
1 parent 2c7c172
commit 11ec9d4
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/pkg/driver/kubernetes/driver.go b/pkg/driver/kubernetes/driver.go
@@ -298,12 +298,12 @@ func (d *Driver) GetVersion(ctx context.Context) (string, error) {
 			Stderr:    true,
 			TTY:       false,
 		}, scheme.ParameterCodec)
+	req.Timeout(10 * time.Second)
 	u := req.URL()
 	exec, err := remotecommand.NewSPDYExecutor(restClientConfig, "POST", u)
 	if err != nil {
 		return "", err
 	}
-	// TODO how to timeout if something goes bad...?
 	serr := exec.Stream(remotecommand.StreamOptions{
 		Stdout: buf,
 		Stderr: os.Stderr,