Reformat

atlanticwave-sdx · Oct 28, 2024 · ddbdc44 · ddbdc44
1 parent c761fc4
commit ddbdc44
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 6 deletions.
diff --git a/sdx_controller/handlers/lc_message_handler.py b/sdx_controller/handlers/lc_message_handler.py
@@ -57,10 +57,10 @@ def process_lc_json_msg(
             logger.info("Adding topology to TE manager")
             self.te_manager.add_topology(msg_json)
             num_domain_topos = len(domain_list)
-        
+
         self.db_instance.add_key_value_pair_to_db(
-                "topologies", "num_domain_topos", num_domain_topos
-            )
+            "topologies", "num_domain_topos", num_domain_topos
+        )
         db_key = "LC-" + str(num_domain_topos)
         logger.info(f"Adding topology {db_key} to db.")
         self.db_instance.add_key_value_pair_to_db(

diff --git a/sdx_controller/messaging/rpc_queue_consumer.py b/sdx_controller/messaging/rpc_queue_consumer.py
@@ -134,19 +134,18 @@ def start_sdx_consumer(self, thread_queue, db_instance):
                 HEARTBEAT_ID += 1
                 logger.debug("Heart beat received. ID: " + str(HEARTBEAT_ID))
                 continue
-            
+
             if not parse_helper.is_json(msg):
                 continue
 
             if "version" not in str(msg):
                 logger.info("Got message (NO VERSION) from MQ: " + str(msg))
-            
+
             lc_message_handler.process_lc_json_msg(
                 msg,
                 latest_topo,
                 domain_list,
             )
-
 
     def stop_threads(self):
         """