close the pool.

pull/1648/head
Michael DeHaan 12 years ago
parent 92ce8a0517
commit f1f44843c3

@ -564,10 +564,12 @@ class Runner(object):
p = multiprocessing.Pool(self.forks) p = multiprocessing.Pool(self.forks)
try: try:
return p.map(_executor_hook, hosts) result = p.map(_executor_hook, hosts)
p.close()
except KeyboardInterrupt: except KeyboardInterrupt:
p.terminate() p.terminate()
raise errors.AnsibleError("Interrupted") raise errors.AnsibleError("Interrupted")
return result
# ***************************************************** # *****************************************************

Loading…
Cancel
Save