process_comms.py / process_states.py

src/plumpy/persistence.py

@@ -345,7 +345,7 @@ def delete_process_checkpoints(self, pid: PID_TYPE) -> None:
             del self._checkpoints[pid]
 
 
-SavableClsType = TypeVar('SavableClsType', bound='Type[Savable]')  # type: ignore[name-defined]  # pylint: disable=invalid-name
+SavableClsType = TypeVar('SavableClsType', bound='type[Savable]')
 
 
 def auto_persist(*members: str) -> Callable[[SavableClsType], SavableClsType]:

src/plumpy/process_comms.py

@@ -567,7 +567,8 @@ async def _launch(
             self._persister.save_checkpoint(proc)
 
         if nowait:
-            asyncio.ensure_future(proc.step_until_terminated())
+            # XXX: can return a reference and gracefully use task to cancel itself when the upper call stack fails
+            asyncio.ensure_future(proc.step_until_terminated())  # noqa: RUF006
             return proc.pid
 
         await proc.step_until_terminated()
@@ -594,7 +595,8 @@ async def _continue(
         proc = cast('Process', saved_state.unbundle(self._load_context))
 
         if nowait:
-            asyncio.ensure_future(proc.step_until_terminated())
+            # XXX: can return a reference and gracefully use task to cancel itself when the upper call stack fails
+            asyncio.ensure_future(proc.step_until_terminated())  # noqa: RUF006
             return proc.pid
 
         await proc.step_until_terminated()

src/plumpy/process_states.py

@@ -43,7 +43,7 @@
     from .processes import Process  # pylint: disable=cyclic-import
 
 
-class Interruption(Exception):
+class Interruption(Exception):  # noqa: N818
     pass