CORD-3054 delete steps for k8s synchronizer
Change-Id: I95d61ae5837892e3d7783791506d9ba6d7babcb4
diff --git a/xos/synchronizer/steps/sync_kubernetesserviceinstance.py b/xos/synchronizer/steps/sync_kubernetesserviceinstance.py
index 4f1088a..21657b6 100644
--- a/xos/synchronizer/steps/sync_kubernetesserviceinstance.py
+++ b/xos/synchronizer/steps/sync_kubernetesserviceinstance.py
@@ -147,7 +147,13 @@
o.backend_handle = pod.metadata.self_link
o.save(update_fields=["backend_handle"])
- def delete_record(self, port):
- # TODO(smbaker): Implement delete step
- pass
+ def delete_record(self, o):
+ secret = self.get_pod(o)
+ if not secret:
+ log.info("Kubernetes pod does not exist; Nothing to delete.", o=o)
+ return
+ delete_options = self.kubernetes_client.V1DeleteOptions()
+ self.v1core.delete_namespaced_pod(o.name, o.slice.trust_domain.name, delete_options)
+ log.info("Deleted pod from kubernetes", handle=o.backend_handle)
+