From 947fa3be85a26d914f7428e124a088c334bd79f8 Mon Sep 17 00:00:00 2001 From: Jusong Yu Date: Tue, 17 Dec 2024 18:52:50 +0100 Subject: [PATCH] Cover test for broadcast_send of process enter and move coordinator logic out --- src/plumpy/processes.py | 1 + 1 file changed, 1 insertion(+) diff --git a/src/plumpy/processes.py b/src/plumpy/processes.py index a947eaba..4da9cc06 100644 --- a/src/plumpy/processes.py +++ b/src/plumpy/processes.py @@ -741,6 +741,7 @@ def on_entered(self, from_state: Optional[process_states.State]) -> None: call_with_super_check(self.on_killed) if self._coordinator and isinstance(self.state, enum.Enum): + # FIXME: this part should be tested first # FIXME: move all to `coordinator.broadcast()` call and in rmq implement coordinator from plumpy.rmq.exceptions import CommunicatorChannelInvalidStateError, CommunicatorConnectionClosed