From 9806f89a049e48a0c8606830be589954cf8b3f32 Mon Sep 17 00:00:00 2001 From: James Cammarata Date: Thu, 29 Aug 2013 10:59:34 -0500 Subject: [PATCH] Revert "Construct the multiprocessing manager only once." This reverts commit 1d13ec2da358b3198f78370a0fe02e1ee9893c64. --- lib/ansible/runner/__init__.py | 3 +-- 1 file changed, 1 insertion(+), 2 deletions(-) diff --git a/lib/ansible/runner/__init__.py b/lib/ansible/runner/__init__.py index 45e6cb8d07..1d993d4cc3 100644 --- a/lib/ansible/runner/__init__.py +++ b/lib/ansible/runner/__init__.py @@ -55,7 +55,6 @@ multiprocessing_runner = None OUTPUT_LOCKFILE = tempfile.TemporaryFile() PROCESS_LOCKFILE = tempfile.TemporaryFile() -MULTIPROCESSING_MANAGER = multiprocessing.Manager() ################################################ @@ -830,7 +829,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)