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()