experimenting with time limits for threading.Barrier

chalmerlowe · chalmerlowe · commit 2f3e30a637e7 · 2025-10-21T06:14:44.000-04:00
diff --git a/tests/system.py b/tests/system.py
@@ -732,7 +732,7 @@ def callback(message):
 
         # The messages that were not processed should have been NACK-ed and we should
         # receive them again quite soon.
-        all_done = threading.Barrier(7 + 1, timeout=5)  # +1 because of the main thread
+        all_done = threading.Barrier(7 + 1, timeout=15)  # +1 because of the main thread
         remaining = []
 
         def callback2(message):
