Thread hang with waiter.acquire() in fillQueue

[Nitin-Asthana]

threshold = deduper.threshold(data, recall_weight=2)
File "C:\Python27\lib\site-packages\dedupe\api.py", line 245, in threshold
return self.thresholdBlocks(blocked_pairs, recall_weight)
File "C:\Python27\lib\site-packages\dedupe\api.py", line 75, in thresholdBlocks
self.num_cores)['score']
File "C:\Python27\lib\site-packages\dedupe\core.py", line 229, in scoreDuplicates
fillQueue(record_pairs_queue, records, n_map_processes)
File "C:\Python27\lib\site-packages\dedupe\core.py", line 263, in fillQueue
queue.put(chunk)
File "C:\Python27\lib\Queue.py", line 126, in put
self.not_full.wait()
File "C:\Python27\lib\threading.py", line 340, in wait
waiter.acquire()

Program gets into Infinite wait/hang in threshold function.

Did anyone encountered same issue? Any help is appreciated.

[fgregg]

Please provide a short code example that reproduces this problem.