fix _pipe_log_stream not running consistently for monitored subprocess

permitio · Nov 5, 2024 · 778cc6f · 778cc6f
1 parent 23006ab
commit 778cc6f
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/packages/opal-client/opal_client/engine/runner.py b/packages/opal-client/opal_client/engine/runner.py
@@ -136,8 +136,8 @@ async def _pipe_logs_stream(stream: asyncio.StreamReader):
 
                 line = b""
 
-        await asyncio.wait(
-            [
+        await asyncio.gather(
+            *[
                 _pipe_logs_stream(self._process.stdout),
                 _pipe_logs_stream(self._process.stderr),
             ]