diff --git a/lib/ansible/executor/task_queue_manager.py b/lib/ansible/executor/task_queue_manager.py index 9d0dd74e7cc..e39e6d5707d 100644 --- a/lib/ansible/executor/task_queue_manager.py +++ b/lib/ansible/executor/task_queue_manager.py @@ -177,8 +177,7 @@ class TaskQueueManager: are done with the current task). ''' - # Treat "forks" config parameter as max value. Only create number of workers - # equal to number of hosts in inventory if less than max value. + # Fork # of forks, # of hosts or serial, whichever is lowest contenders = [self._options.forks, play.serial, len(self._inventory.get_hosts(play.hosts))] contenders = [ v for v in contenders if v is not None and v > 0 ] self._initialize_workers(min( contenders ))