diff --git a/features/environment.py b/features/environment.py
index 4f304f81..19dc7974 100644
--- a/features/environment.py
+++ b/features/environment.py
@@ -473,7 +473,7 @@ class KubernetesController(AbstractDcsController):
 
     def delete_pod(self, name):
         try:
-            self._api.delete_namespaced_pod(name, self._namespace, self._client.V1DeleteOptions())
+            self._api.delete_namespaced_pod(name, self._namespace, body=self._client.V1DeleteOptions())
         except:
             pass
         while True:
diff --git a/requirements.txt b/requirements.txt
index 17a3aa8b..02f97f64 100644
--- a/requirements.txt
+++ b/requirements.txt
@@ -5,11 +5,11 @@ requests
 six >= 1.7
 kazoo>=1.3.1
 python-etcd>=0.4.3,<0.5
-python-consul>=0.7.0
+python-consul>=0.7.1
 click>=4.1
 prettytable>=0.7
 tzlocal
 python-dateutil
 psutil>=2.0.0
 cdiff
-kubernetes>=2.0.0,<=7.0.0,!=4.0.*,!=5.0.*
+kubernetes>=2.0.0,<=10.0.1,!=4.0.*,!=5.0.*
diff --git a/tests/test_kubernetes.py b/tests/test_kubernetes.py
index 2faa41a4..c16bd7ce 100644
--- a/tests/test_kubernetes.py
+++ b/tests/test_kubernetes.py
@@ -29,12 +29,14 @@ def mock_list_namespaced_pod(self, *args, **kwargs):
 
 @patch.object(k8s_client.CoreV1Api, 'patch_namespaced_config_map', Mock())
 @patch.object(k8s_client.CoreV1Api, 'create_namespaced_config_map', Mock())
+@patch('kubernetes.client.api_client.ThreadPool', Mock(), create=True)
 @patch.object(Thread, 'start', Mock())
 class TestKubernetes(unittest.TestCase):
 
     @patch('kubernetes.config.load_kube_config', Mock())
     @patch.object(k8s_client.CoreV1Api, 'list_namespaced_config_map', mock_list_namespaced_config_map)
     @patch.object(k8s_client.CoreV1Api, 'list_namespaced_pod', mock_list_namespaced_pod)
+    @patch('kubernetes.client.api_client.ThreadPool', Mock(), create=True)
     @patch.object(Thread, 'start', Mock())
     def setUp(self):
         self.k = Kubernetes({'ttl': 30, 'scope': 'test', 'name': 'p-0', 'retry_timeout': 10, 'labels': {'f': 'b'}})
@@ -135,6 +137,7 @@ class TestKubernetes(unittest.TestCase):
 class TestKubernetesWatcher(unittest.TestCase):
 
     @patch('kubernetes.config.load_kube_config', Mock())
+    @patch('kubernetes.client.api_client.ThreadPool', Mock(), create=True)
     @patch.object(Thread, 'start', Mock())
     def setUp(self):
         self.k = Kubernetes({'ttl': 30, 'scope': 'test', 'name': 'p-0', 'retry_timeout': 10, 'labels': {'f': 'b'}})