Fix[IT]: fix zombie broker and output mess (#887)

Signed-off-by: Anton Pryakhin <[email protected]>

Author: waldgange

src/integration-tests/test_connection_loss.py

@@ -178,12 +178,6 @@ def test_force_leader_primary_divergence(
     assert rc == 0
 
     # Restart "east1"
-    old_leader = Broker(
-        old_leader,
-        cluster=cluster,
-        cwd=cluster.work_dir / old_leader.name,
-    )
-    old_leader.add_sync_log_hook(lambda _: cluster.check_processes())
     old_leader.start()
     old_leader.wait_until_started()
 

src/python/blazingmq/dev/it/process/proc.py

@@ -137,7 +137,7 @@ def __init__(
         self,
         name,
         command,
-        stdin=None,
+        stdin=subprocess.DEVNULL,
         read_timeout=5.0,
         wait_timeout=15.0,
         check_exit_code=True,
@@ -459,11 +459,9 @@ def wait(self, timeout: Optional[float] = None) -> int:
             except subprocess.TimeoutExpired:
                 return 1
 
-            self._internal_logger.debug(
-                "waiting for stdout consuming thread to exit..."
-            )
-            self._stdout_thread.join()
-            self._stderr_thread.join()
+        self._internal_logger.debug("waiting for stdout consuming thread to exit...")
+        self._stdout_thread.join()
+        self._stderr_thread.join()
 
         if self.check_exit_code:
             if not self.is_alive() and self.returncode != 0: