From 09012602c22f491b4d95d4b7c69c652e94502eba Mon Sep 17 00:00:00 2001 From: Jusong Yu Date: Fri, 31 Jan 2025 21:34:57 +0100 Subject: [PATCH] Use asyncio.run --- src/plumpy/processes.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/src/plumpy/processes.py b/src/plumpy/processes.py index 36bef047..94129464 100644 --- a/src/plumpy/processes.py +++ b/src/plumpy/processes.py @@ -1315,7 +1315,7 @@ def execute(self) -> dict[str, Any] | None: :return: None if not terminated, otherwise `self.outputs` """ if not self.has_terminated(): - self.loop.run_until_complete(self.step_until_terminated()) + asyncio.run(self.step_until_terminated()) return self.future().result()