Cover test for broadcast_send of process enter and move coordinator l…

…ogic out
aiidateam · Dec 17, 2024 · 947fa3b · 947fa3b
1 parent 8fcd597
commit 947fa3b
Showing 1 changed file with 1 addition and 0 deletions.
diff --git 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