don't limit size of exception queue

dedupeio · Jan 20, 2022 · 3cec4ff · 3cec4ff
1 parent 30df5aa
commit 3cec4ff
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/dedupe/core.py b/dedupe/core.py
@@ -190,7 +190,7 @@ def scoreDuplicates(record_pairs: RecordPairs,
                             "the data you trained on?")
 
     record_pairs_queue: _Queue = Queue(2)
-    exception_queue: _Queue = Queue(1)
+    exception_queue: _Queue = Queue()
     scored_pairs_file, score_file_path = tempfile.mkstemp()
     os.close(scored_pairs_file)