pool.join required to wait for processes to finish (#436)

This commit is contained in:
Ross Scroggs
2017-02-19 07:53:42 -08:00
committed by Jay Lee
parent 26960c96d9
commit 6a2925c546

View File

@@ -10016,6 +10016,7 @@ def run_batch(items):
if item[0] == u'commit-batch':
sys.stderr.write(u'commit-batch - waiting for running processes to finish before proceeding...')
pool.close()
pool.join()
pool = Pool(num_worker_threads, init_gam_worker)
sys.stderr.write(u'done with commit-batch\n')
continue