From e625862143d6f61f2b47c737062c42db690a47ce Mon Sep 17 00:00:00 2001 From: Jusong Yu Date: Sat, 21 Dec 2024 12:16:41 +0100 Subject: [PATCH] Typing todo note --- src/plumpy/coordinator.py | 2 ++ src/plumpy/rmq/process_control.py | 2 ++ 2 files changed, 4 insertions(+) diff --git a/src/plumpy/coordinator.py b/src/plumpy/coordinator.py index 29533bf4..dc501c4e 100644 --- a/src/plumpy/coordinator.py +++ b/src/plumpy/coordinator.py @@ -45,3 +45,5 @@ def broadcast_send( ) -> Any: ... def task_send(self, task: Any, no_reply: bool = False) -> Any: ... + + def close(self) -> None: ... diff --git a/src/plumpy/rmq/process_control.py b/src/plumpy/rmq/process_control.py index 74595dec..bdf95ee7 100644 --- a/src/plumpy/rmq/process_control.py +++ b/src/plumpy/rmq/process_control.py @@ -29,6 +29,7 @@ ProcessStatus = Any +# FIXME: the class not fit typing of ProcessController protocol class RemoteProcessController: """ Control remote processes using coroutines that will send messages and wait @@ -189,6 +190,7 @@ async def execute_process( return result +# FIXME: the class not fit typing of ProcessController protocol class RemoteProcessThreadController: """ A class that can be used to control and launch remote processes