asyncio.wait to asyncio.gather for coroutines in opa client engine

permitio · Jan 9, 2024 · 68f1e6a · 68f1e6a
1 parent f1cbc2b
commit 68f1e6a
Showing 1 changed file with 3 additions and 5 deletions.
diff --git a/packages/opal-client/opal_client/engine/runner.py b/packages/opal-client/opal_client/engine/runner.py
@@ -130,11 +130,9 @@ async def _run_process_until_terminated(self) -> int:
         )
 
         if self._piped_logs_format != EngineLogFormat.NONE:
-            await asyncio.wait(
-                [
-                    self.pipe_logs(self._process.stdout, self._piped_logs_format),
-                    self.pipe_logs(self._process.stderr, self._piped_logs_format),
-                ]
+            await asyncio.gather(
+                self.pipe_logs(self._process.stdout, self._piped_logs_format),
+                self.pipe_logs(self._process.stderr, self._piped_logs_format)
             )
 
         return_code = await self._process.wait()