Update sdx_lc/messaging/topic_queue_consumer.py

Co-authored-by: Sajith Sasidharan <[email protected]>
atlanticwave-sdx · Jun 12, 2024 · 4c8846d · 4c8846d
1 parent 5791750
commit 4c8846d
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/sdx_lc/messaging/topic_queue_consumer.py b/sdx_lc/messaging/topic_queue_consumer.py
@@ -106,7 +106,7 @@ def handle_mq_msg(self, msg_body):
                 self.message_id += 1
                 self.logger.info("Sending connection info to OXP.")
                 # send connection info to OXP
-                if msg_json["operation"] == "post":
+                if msg_json.get("operation") == "post":
                     try:
                         r = requests.post(str(OXP_CONNECTION_URL), json=connection)
                         self.logger.info(f"Status from OXP: {r}")