From 658bb94ae3148c0091aa961c4c59b42a692ccd72 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Bj=C3=B6rn=20Vonheiden?= <bjoern.vonheiden@hotmail.de>
Date: Wed, 23 Sep 2020 11:43:20 +0200
Subject: [PATCH] Delete lag exporter with kubernetes api in run uc py
---
execution/run_uc.py | 31 ++++++++++++-------------------
1 file changed, 12 insertions(+), 19 deletions(-)
diff --git a/execution/run_uc.py b/execution/run_uc.py
index fa25f4d86..81cda8881 100644
--- a/execution/run_uc.py
+++ b/execution/run_uc.py
@@ -477,25 +477,18 @@ def stop_lag_exporter():
"""
print('Stop the lag exporter')
- find_pod_command = [
- 'kubectl',
- 'get',
- 'pod',
- '-l',
- 'app.kubernetes.io/name=kafka-lag-exporter',
- '-o',
- 'jsonpath="{.items[0].metadata.name}"'
- ]
- output = subprocess.run(find_pod_command, capture_output=True, text=True)
- lag_exporter_pod = output.stdout.replace('"', '')
- delete_pod_command = [
- 'kubectl',
- 'delete',
- 'pod',
- lag_exporter_pod
- ]
- output = subprocess.run(delete_pod_command, capture_output=True, text=True)
- print(output)
+ try:
+ # Get lag exporter
+ pod_list = coreApi.list_namespaced_pod(namespace='default', label_selector='app.kubernetes.io/name=kafka-lag-exporter')
+ lag_exporter_pod = pod_list.items[0].metadata.name
+
+ # Delete lag exporter pod
+ res = coreApi.delete_namespaced_pod(name=lag_exporter_pod, namespace='default')
+ except ApiException as e:
+ logging.error('Exception while stopping lag exporter')
+ logging.error(e)
+
+ print('Deleted lag exporter pod: ' + lag_exporter_pod)
return
--
GitLab