#566: corrected incorrect handling of Bool/int

Author: ppebay

config/synthetic-blocks.yaml

@@ -43,7 +43,7 @@ visualization:
   output_visualization_file_stem: output_file
 
 write_JSON:
-  compressed: False
+  compressed: false
   suffix: json
-  communications: True
-  offline_LB_compatible: True
+  communications: true
+  offline_LB_compatible: true

src/lbaf/Applications/LBAF_app.py

@@ -589,7 +589,7 @@ def run(self, cfg=None, cfg_dir=None):
             "offline_LB_compatible", False)
         rebalanced_phase = runtime.execute(
             self.__parameters.algorithm.get("phase_id", 0),
-            offline_LB_compatible)
+            1 if offline_LB_compatible else 0)
 
         # Instantiate phase to VT file writer when requested
         if self.__json_writer:
@@ -618,8 +618,9 @@ def run(self, cfg=None, cfg_dir=None):
                     f"Writing all ({len(phases)}) phases for offline load-balancing")
                 self.__json_writer.write(phases)
             else:
-                self.__logger.info(f"Writing single phase {phase_id} to JSON files")
-                self.__json_writer.write(
+                # Add new phase when load balancing when offline mode not selected
+                self.__logger.info(f"Creating rebalanced phase {phase_id}")
+                self.__jsoTn_writer.write(
                     {phase_id: rebalanced_phase})
 
         # Generate meshes and multimedia when requested

src/lbaf/Execution/lbsInformAndTransferAlgorithm.py

@@ -128,7 +128,7 @@ def __process_message(self, r_rcv: Rank, m: Message):
         # Process the message
         self.__known_peers[r_rcv].update(m.get_support())
 
-    def __forward_message(self, i: int, r_snd: Rank, f:int):
+    def __forward_message(self, i: int, r_snd: Rank, f: int):
         """Forward information message to rank peers sampled from known ones."""
         # Make rank aware of itself
         if r_snd not in self.__known_peers:

src/lbaf/Execution/lbsRuntime.py

@@ -130,9 +130,9 @@ def get_statistics(self):
         """Return runtime statistics."""
         return self.__statistics
 
-    def execute(self, p_id: int, phase_increment=0):
+    def execute(self, p_id: int, phase_increment: int=0):
         """Execute runtime for single phase with given ID or multiple phases in selected range."""
-        # Execute balancing algorithm
+        # Execute load balancing algorithm
         self.__logger.info(
             f"Executing {type(self.__algorithm).__name__} for "
             + ("all phases" if p_id < 0 else f"phase {p_id}"))
@@ -145,11 +145,13 @@ def execute(self, p_id: int, phase_increment=0):
 
         # Retrieve possibly null rebalanced phase and return it
         if (pp := self.__algorithm.get_rebalanced_phase()):
+            # Increment rebalanced phase ID as requested
             pp.set_id((pp_id := pp.get_id() + phase_increment))
 
             # Share communications from original phase with new phase
             initial_communications = self.__algorithm.get_initial_communications()
             pp.set_communications(initial_communications[p_id])
-
             self.__logger.info(f"Created rebalanced phase {pp_id}")
+
+        # Return rebalanced phase
         return pp