From 110eb466bd5a427299de1398593986592a072bc1 Mon Sep 17 00:00:00 2001
From: Radomir Stevanovic <radomir@dwavesys.com>
Date: Fri, 23 Dec 2022 04:04:06 -0800
Subject: [PATCH] Use blocking get when testing multiprocessing.Queue

Reason: in mp, put is async, it takes nonzero time.

Fix #279.
---
 tests/test_flow.py | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/tests/test_flow.py b/tests/test_flow.py
index e686413..ffbc361 100644
--- a/tests/test_flow.py
+++ b/tests/test_flow.py
@@ -1079,7 +1079,7 @@ def test_shared_memo_queue(self, memo):
         res = []
         while True:
             try:
-                res.append(memo.get_nowait())
+                res.append(memo.get(timeout=1))
             except queue.Empty:
                 break