wbrawner/ansible
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

treat forks config parameter as max value instead of always creating that number of workers

Browse source
This commit is contained in:
Lars Larsson 2015-11-04 17:13:26 +01:00
parent 38cc0705c6
commit 3289670a04
1 changed files with 7 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

9
lib/ansible/executor/task_queue_manager.py
View file

@ -92,8 +92,14 @@ class TaskQueueManager:
# plugins for inter-process locking.
self._connection_lockfile = tempfile.TemporaryFile()
# Treat "forks" config parameter as max value. Only create number of workers
# equal to number of hosts in inventory if less than max value.
num_workers = self._options.forks
if self._options.forks > len(self._inventory.list_hosts()):
num_workers = len(self._inventory.list_hosts())
self._workers = []
for i in range(self._options.forks):
for i in range(num_workers):
main_q = multiprocessing.Queue()
rslt_q = multiprocessing.Queue()
@ -266,4 +272,3 @@ class TaskQueueManager:
method(*args, **kwargs)
except Exception as e:
self._display.warning('Error when using %s: %s' % (method, str(e)))