CORTX-29710: Hare-HA - Correct the message format sent from Hare to ha

Solution: Fixed format by removing json.dump() Also fixed 'degraded' event related issue Signed-off-by: Swapnil Gaonkar <swapnil.gaonkar@seagate.com>
Seagate · Jun 9, 2022 · c239790 · c239790
1 parent 3d3ecc1
commit c239790
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 3 deletions.
diff --git a/hax/hax/ha/message_interface/message_interface.py b/hax/hax/ha/message_interface/message_interface.py
@@ -89,8 +89,7 @@ def initialize_bus(self, util: ConsulUtil):
             raise Exception('initialize_bus skipped as configpath not found')
 
     def send(self, event: HaEvent):
-        event_to_send = json.dumps(event)
-        self.producer.send([event_to_send])
+        self.producer.send([event])
 
     def _register_message_type(self, message_type,
                                partitions: int = 1):

diff --git a/hax/hax/util.py b/hax/hax/util.py
@@ -2033,7 +2033,7 @@ def get_process_based_node_state(self, node_fid: Fid) -> str:
                 started_processes += 1
         LOG.debug('total procs=%s, started procs=%s', total_processes,
                   started_processes)
-        fin_state = 'degarded'
+        fin_state = 'degraded'
         if total_processes == started_processes:
             fin_state = 'online'
         elif started_processes == 0: