From: garciadeblas Date: Wed, 5 Nov 2025 10:55:37 +0000 (+0100) Subject: Feature 11073: Fix send of kafka message X-Git-Url: https://osm.etsi.org/gitweb/?a=commitdiff_plain;h=be6498e2668464d66b491bd12f694e2413ab8a35;p=osm%2FNBI.git Feature 11073: Fix send of kafka message Change-Id: Ie3f5d58995778e3b2db700698996c868899b8f0f Signed-off-by: garciadeblas --- 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,