Adds explicit pool close/join in handleEntities to fix possible hang (#1817)
This commit is contained in:
@@ -217,6 +217,8 @@ def handleEntities(rset, config, config_path, filters, markers):
|
|||||||
|
|
||||||
results = pool.map(parseBucketChunks, ((buck, rset, filters) for buck in buckets))
|
results = pool.map(parseBucketChunks, ((buck, rset, filters) for buck in buckets))
|
||||||
|
|
||||||
|
pool.close()
|
||||||
|
pool.join()
|
||||||
logging.info("All the threads completed.")
|
logging.info("All the threads completed.")
|
||||||
|
|
||||||
for marker_dict in results:
|
for marker_dict in results:
|
||||||
|
|||||||
Reference in New Issue
Block a user