From 5ecd8fb57c613c1bb4362c3860934c7a0003dff2 Mon Sep 17 00:00:00 2001 From: Vanshdeep Singh Date: Tue, 31 Jul 2018 11:41:36 +0200 Subject: [PATCH] Problem: No wait when getting value from queue Solution: Random failure of test `tests/test_events.py::test_event_handler_raises_when_called_after_start` seem to be because of `get_nowait` which returns way to quickly even when the queue has data --- bigchaindb/events.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/bigchaindb/events.py b/bigchaindb/events.py index 7959d284..e60fe44f 100644 --- a/bigchaindb/events.py +++ b/bigchaindb/events.py @@ -67,7 +67,7 @@ class Exchange: """ try: - self.started_queue.get_nowait() + self.started_queue.get(timeout=0.01) raise RuntimeError('Cannot create a new subscriber queue while Exchange is running.') except Empty: pass