The interface_zmq.py test has been flaky due to a race condition - sometimes ZMQ messages aren’t available immediately when we try to read them.
This adds a simple retry mechanism: if the message isn’t ready, we’ll retry up to 5 times with a 0.1s delay between attempts. Instead of crashing on zmq.error.Again exceptions, the test now handles them gracefully.
Fixes #34189
The following sections might be updated with supplementary metadata relevant to reviewers and maintainers.
See the guideline for information on the review process. A summary of reviews will appear here.
The test_zmq.py functional test occasionally failed due to ZMQ messages
not being immediately available when checked. Added retry mechanism with
exponential backoff (5 attempts, 0.1s delay) to handle transient ZMQ
message delivery timing issues.
Fixes #34189
54@@ -54,7 +55,17 @@ def __init__(self, socket, topic):
55
56 # Receive message from publisher and verify that topic and sequence match
57 def _receive_from_publisher_and_check(self):
58- topic, body, seq = self.socket.recv_multipart()
59+ max_retries = 5
60+ retry_delay = 0.1
