Use asyncio.run

unkcpz · Jan 31, 2025 · 0901260 · 0901260
1 parent b914781
commit 0901260
Showing 1 changed file with 1 addition and 1 deletion.
diff --git 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()