Revert "Construct the multiprocessing manager only once."

This reverts commit 1d13ec2d.

Revert "Construct the multiprocessing manager only once."
This reverts commit 1d13ec2d.
9806f89a · James Cammarata · 39fe40bb · 9806f89a
Commit 9806f89a authored Aug 29, 2013 by James Cammarata
Hide whitespace changes
Inline Side-by-side

Showing with 1 additions and 2 deletions

lib/ansible/runner/__init__.py
+1 -2

No files found.
--- 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)