fix: context cancel (#1350)

Co-authored-by: Asim Aslam <asim@aslam.me>
micro · Mar 16, 2020 · 5712aaf · 5712aaf
1 parent ac333d9
commit 5712aaf
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/util/kubernetes/client/watch.go b/util/kubernetes/client/watch.go
@@ -98,10 +98,12 @@ func newWatcher(req *api.Request) (Watcher, error) {
 	// do the raw request
 	res, err := req.Raw()
 	if err != nil {
+		cancel()
 		return nil, err
 	}
 
 	if res.StatusCode < 200 || res.StatusCode >= 300 {
+		cancel()
 		// close the response body
 		res.Body.Close()
 		// return an error