From 63ab0ab0608b6ddf733b800f79147158848cf2a7 Mon Sep 17 00:00:00 2001 From: Cong Wang Date: Tue, 19 Sep 2023 14:22:02 -0400 Subject: [PATCH] Handle empty link_connection_dict --- swagger_server/handlers/connection_handler.py | 5 ++++- swagger_server/messaging/rpc_queue_consumer.py | 8 +++----- 2 files changed, 7 insertions(+), 6 deletions(-) diff --git a/swagger_server/handlers/connection_handler.py b/swagger_server/handlers/connection_handler.py index 1cd32965..69136bb9 100644 --- a/swagger_server/handlers/connection_handler.py +++ b/swagger_server/handlers/connection_handler.py @@ -148,7 +148,10 @@ def handle_link_failure(self, msg_json): "link_connections_dict" ) - if not link_connections_dict_str: + if ( + not link_connections_dict_str + or not link_connections_dict_str["link_connections_dict"] + ): logger.debug("No connection has been placed yet.") return diff --git a/swagger_server/messaging/rpc_queue_consumer.py b/swagger_server/messaging/rpc_queue_consumer.py index c22b11e0..1128a695 100644 --- a/swagger_server/messaging/rpc_queue_consumer.py +++ b/swagger_server/messaging/rpc_queue_consumer.py @@ -126,9 +126,7 @@ def start_sdx_consumer(self, thread_queue, db_instance): logger.info("got message from MQ: " + str(msg)) else: db_instance.add_key_value_pair_to_db(str(MESSAGE_ID), msg) - logger.debug("Save to database complete.") - logger.debug("message ID:" + str(MESSAGE_ID)) - value = db_instance.read_from_db(str(MESSAGE_ID)) - logger.debug("got value from DB:") - logger.debug(value) + logger.debug( + "Save to database complete. message ID: " + str(MESSAGE_ID) + ) MESSAGE_ID += 1