diff options
| author | James Cammarata <jimi@sngx.net> | 2015-11-04 11:26:06 -0500 |
|---|---|---|
| committer | James Cammarata <jimi@sngx.net> | 2015-11-04 11:26:06 -0500 |
| commit | 89d713aa520fe17131efe78218f20ad09fe99688 (patch) | |
| tree | 08105f897a84dff59371a36c5f0d4e558c75dd1f /lib/ansible/executor/task_queue_manager.py | |
| parent | 61ace1d3c486b294a1badad7b5f60fc40b763755 (diff) | |
| download | ansible-perf_improvements.tar.gz | |
Fixing up performanceperf_improvements
Diffstat (limited to 'lib/ansible/executor/task_queue_manager.py')
| -rw-r--r-- | lib/ansible/executor/task_queue_manager.py | 7 |
1 files changed, 6 insertions, 1 deletions
diff --git a/lib/ansible/executor/task_queue_manager.py b/lib/ansible/executor/task_queue_manager.py index ae41afb600..b18e07a544 100644 --- a/lib/ansible/executor/task_queue_manager.py +++ b/lib/ansible/executor/task_queue_manager.py @@ -92,8 +92,13 @@ class TaskQueueManager: # plugins for inter-process locking. self._connection_lockfile = tempfile.TemporaryFile() + num_hosts = len(inventory.get_hosts()) + num_workers = self._options.forks + if num_workers > num_hosts: + num_workers = num_hosts + self._workers = [] - for i in range(self._options.forks): + for i in xrange(num_workers): main_q = multiprocessing.Queue() rslt_q = multiprocessing.Queue() |