diff --git a/kubernetes/base/config/exec_provider.py b/kubernetes/base/config/exec_provider.py index 317a56695..03dc0386e 100644 --- a/kubernetes/base/config/exec_provider.py +++ b/kubernetes/base/config/exec_provider.py @@ -71,7 +71,7 @@ def run(self, previous_response=None): if previous_response: kubernetes_exec_info['spec']['response'] = previous_response if self.cluster: - kubernetes_exec_info['spec']['cluster'] = self.cluster + kubernetes_exec_info['spec']['cluster'] = self.cluster.value self.env['KUBERNETES_EXEC_INFO'] = json.dumps(kubernetes_exec_info) process = subprocess.Popen( diff --git a/kubernetes/base/config/exec_provider_test.py b/kubernetes/base/config/exec_provider_test.py index 9ff62d12e..fc4944b22 100644 --- a/kubernetes/base/config/exec_provider_test.py +++ b/kubernetes/base/config/exec_provider_test.py @@ -175,7 +175,7 @@ def test_with_cluster_info(self, mock): instance = mock.return_value instance.wait.return_value = 0 instance.communicate.return_value = (self.output_ok, '') - ep = ExecProvider(self.input_with_cluster, None, {'server': 'name.company.com'}) + ep = ExecProvider(self.input_with_cluster, None, ConfigNode("cluster", {'server': 'name.company.com'})) result = ep.run() self.assertTrue(isinstance(result, dict)) self.assertTrue('token' in result)