Commit d034b32f authored by Florent Xicluna's avatar Florent Xicluna

On finalize, don't try to join not started process.

parent faf17538
...@@ -447,12 +447,10 @@ class Pool(object): ...@@ -447,12 +447,10 @@ class Pool(object):
if pool and hasattr(pool[0], 'terminate'): if pool and hasattr(pool[0], 'terminate'):
debug('joining pool workers') debug('joining pool workers')
for p in pool: for p in pool:
p.join() if p.is_alive():
for w in pool:
if w.exitcode is None:
# worker has not yet exited # worker has not yet exited
debug('cleaning up worker %s' % w.pid) debug('cleaning up worker %d' % p.pid)
w.join() p.join()
# #
# Class whose instances are returned by `Pool.apply_async()` # Class whose instances are returned by `Pool.apply_async()`
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment