Apply suggestions from code review

Co-authored-by: Thomas Ubensee <[email protected]>
exasol · Aug 29, 2023 · 4ecbf7b · 4ecbf7b
1 parent 9d14a2e
commit 4ecbf7b
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/...alytics_framework/udf_communication/peer_communicator/acknowledge_register_peer_sender.py b/...alytics_framework/udf_communication/peer_communicator/acknowledge_register_peer_sender.py
@@ -57,7 +57,7 @@ def _should_we_send(self):
         return result
 
     def is_ready_to_stop(self):
-        result = (self._finished and self._needs_to_send_for_peer) or not self._needs_to_send_for_peer
+        result = self._finished or not self._needs_to_send_for_peer
         self._logger.debug("is_ready_to_stop", finished=self._finished, is_ready_to_stop=result)
         return result
 

diff --git a/..._advanced_analytics_framework/udf_communication/peer_communicator/register_peer_sender.py b/..._advanced_analytics_framework/udf_communication/peer_communicator/register_peer_sender.py
@@ -57,7 +57,7 @@ def _should_we_send(self):
         return result
 
     def is_ready_to_stop(self):
-        return (self._finished and self._needs_to_send_for_peer) or not self._needs_to_send_for_peer
+        return self._finished or not self._needs_to_send_for_peer
 
 
 class RegisterPeerSenderFactory():