From be6498e2668464d66b491bd12f694e2413ab8a35 Mon Sep 17 00:00:00 2001 From: garciadeblas Date: Wed, 5 Nov 2025 11:55:37 +0100 Subject: [PATCH] Feature 11073: Fix send of kafka message Change-Id: Ie3f5d58995778e3b2db700698996c868899b8f0f Signed-off-by: garciadeblas --- osm_nbi/k8s_topics.py | 5 ++--- osm_nbi/nbi.py | 3 +++ 2 files changed, 5 insertions(+), 3 deletions(-) diff --git a/osm_nbi/k8s_topics.py b/osm_nbi/k8s_topics.py index 23faf29..a1d21b7 100644 --- a/osm_nbi/k8s_topics.py +++ b/osm_nbi/k8s_topics.py @@ -1473,7 +1473,7 @@ class AppInstanceTopic(ACMTopic): _id = self.db.create(self.topic, content) rollback.append({"topic": self.topic, "_id": _id}) - self._send_msg("create", content=content) + self._send_msg("create", {"appinstance": _id, "operation_id": op_id}) return _id, op_id def update_oka_usage_state(self, session, oka_id): @@ -1556,8 +1556,7 @@ class AppInstanceTopic(ACMTopic): operation_params, ) self.db.set_one(self.topic, {"_id": _id}, data) - data = {"appinstance": _id, "operation_id": op_id} - self._send_msg(item, data) + self._send_msg(item, {"appinstance": _id, "operation_id": op_id}) return op_id def delete(self, session, _id, not_send_msg=None): diff --git a/osm_nbi/nbi.py b/osm_nbi/nbi.py index 09ae05d..f723ff5 100644 --- a/osm_nbi/nbi.py +++ b/osm_nbi/nbi.py @@ -2124,6 +2124,9 @@ class Server(object): self._set_location_header(main_topic, version, topic, _id) outdata = {"_id": _id, "id": _id} else: + self.logger.debug( + "Creating new item in topic {}".format(engine_topic) + ) _id, op_id = self.engine.new_item( rollback, engine_session, -- 2.25.1