diff --git a/packages/opal-client/opal_client/engine/runner.py b/packages/opal-client/opal_client/engine/runner.py index 9cca62c28..762472232 100644 --- 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), ]