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
This commit is contained in:
Vanshdeep Singh 2018-07-31 11:41:36 +02:00
parent 4795a78d49
commit 5ecd8fb57c

View File

@ -67,7 +67,7 @@ class Exchange:
""" """
try: 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.') raise RuntimeError('Cannot create a new subscriber queue while Exchange is running.')
except Empty: except Empty:
pass pass