fix wrong block value

piskvorky · Jan 29, 2019 · 124ab37 · 124ab37
1 parent 8fd72d2
commit 124ab37
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/gensim/models/ldamulticore.py b/gensim/models/ldamulticore.py
@@ -289,7 +289,7 @@ def process_result_queue(force=False):
                 # put the chunk into the workers' input job queue
                 while True:
                     try:
-                        job_queue.put((chunk_no, chunk, self.state), block=True)
+                        job_queue.put((chunk_no, chunk, self.state), block=False)
                         queue_size[0] += 1
                         logger.info(
                             "PROGRESS: pass %i, dispatched chunk #%i = documents up to #%i/%i, "