commit 781ce73b106edeb163c52c771380782ef2aaa460
author yshah <shahithya.y@tataelxsi.co.in> Fri Feb 28 08:56:13 2025 +0000
committer garciadeblas <gerardo.garciadeblas@telefonica.com> Tue Mar 18 11:23:13 2025 +0100
tree 0f8f11aa1211d4306251d3bca5ab16c1a51de838
parent 5f41d78fce286143b49bc4111d1db572fb2ac740

Force delete operation passing force option in kafka

Change-Id: I43f0db196ad196aea0a29a0cb567b6cbf3e69cb5
Signed-off-by: yshah <shahithya.y@tataelxsi.co.in>

osm_nbi/acm_topic.py

diff --git a/osm_nbi/acm_topic.py b/osm_nbi/acm_topic.py
index 12ee1a8..8d529aa 100644
--- a/osm_nbi/acm_topic.py
+++ b/osm_nbi/acm_topic.py
@@ -330,7 +330,7 @@
 
     def delete_extra_before(self, session, _id, db_content, not_send_msg=None):
         op_id = self.common_delete(_id, db_content)
-        return {"profile_id": _id, "operation_id": op_id}
+        return {"profile_id": _id, "operation_id": op_id, "force": session["force"]}
 
     def delete_profile(self, session, _id, dry_run=False, not_send_msg=None):
         item_content = self.db.get_one(self.topic, {"_id": _id})

osm_nbi/k8s_topics.py

diff --git a/osm_nbi/k8s_topics.py b/osm_nbi/k8s_topics.py
index 6e7fd25..1e73bb2 100644
--- a/osm_nbi/k8s_topics.py
+++ b/osm_nbi/k8s_topics.py
@@ -557,7 +557,7 @@
 
     def delete_extra_before(self, session, _id, db_content, not_send_msg=None):
         op_id = self.common_delete(_id, db_content)
-        return {"cluster_id": _id, "operation_id": op_id}
+        return {"cluster_id": _id, "operation_id": op_id, "force": session["force"]}
 
     def delete(self, session, _id, dry_run=False, not_send_msg=None):
         filter_q = self._get_project_filter(session)
@@ -969,7 +969,11 @@
                 _id_list.append(_id)
 
         if _id_list:
-            data = {"ksus_list": _id_list, "operation_id": op_id}
+            data = {
+                "ksus_list": _id_list,
+                "operation_id": op_id,
+                "force": session["force"],
+            }
             self._send_msg("delete", data, not_send_msg)
         return op_id
 
@@ -1133,7 +1137,9 @@
         )
         self.db.set_one(self.topic, {"_id": item_content["_id"]}, item_content)
         self._send_msg(
-            "delete", {"oka_id": _id, "operation_id": op_id}, not_send_msg=not_send_msg
+            "delete",
+            {"oka_id": _id, "operation_id": op_id, "force": session["force"]},
+            not_send_msg=not_send_msg,
         )
         return op_id