From e87aa3b87e1294ece14e03da607a212f4054d7f9 Mon Sep 17 00:00:00 2001 From: Marc Sun Date: Tue, 6 Jan 2026 13:49:41 +0000 Subject: [PATCH] fix --- src/accelerate/test_utils/testing.py | 6 ++---- 1 file changed, 2 insertions(+), 4 deletions(-) diff --git a/src/accelerate/test_utils/testing.py b/src/accelerate/test_utils/testing.py index 92b229ff8e4..3e94a0f3628 100644 --- a/src/accelerate/test_utils/testing.py +++ b/src/accelerate/test_utils/testing.py @@ -766,10 +766,8 @@ def execute_subprocess_async(cmd: list, env=None, stdin=None, timeout=180, quiet for i, c in enumerate(cmd): if isinstance(c, Path): cmd[i] = str(c) - loop = asyncio.get_event_loop() - result = loop.run_until_complete( - _stream_subprocess(cmd, env=env, stdin=stdin, timeout=timeout, quiet=quiet, echo=echo) - ) + + result = asyncio.run(_stream_subprocess(cmd, env=env, stdin=stdin, timeout=timeout, quiet=quiet, echo=echo)) cmd_str = " ".join(cmd) if result.returncode > 0: