diff --git a/lib/ansible/runner/__init__.py b/lib/ansible/runner/__init__.py index 277cada1277..8469edd12b0 100644 --- a/lib/ansible/runner/__init__.py +++ b/lib/ansible/runner/__init__.py @@ -54,6 +54,7 @@ multiprocessing_runner = None OUTPUT_LOCKFILE = tempfile.TemporaryFile() PROCESS_LOCKFILE = tempfile.TemporaryFile() +MULTIPROCESSING_MANAGER = multiprocessing.Manager() ################################################ @@ -813,7 +814,7 @@ class Runner(object): def _parallel_exec(self, hosts): ''' handles mulitprocessing when more than 1 fork is required ''' - manager = multiprocessing.Manager() + manager = MULTIPROCESSING_MANAGER job_queue = manager.Queue() for host in hosts: job_queue.put(host)