diff options
| author | James Cammarata <jimi@sngx.net> | 2016-08-26 14:55:56 -0500 |
|---|---|---|
| committer | James Cammarata <jimi@sngx.net> | 2016-08-28 10:19:23 -0500 |
| commit | d5dd191c6c22a5ff23c3a03bb85fe11291fe0b29 (patch) | |
| tree | a801b5f71bbf7b5942201506ffe42f2bb0ac9cb2 /lib/ansible/plugins/strategy/linear.py | |
| parent | 4b679ffd844ee4549c76cd7e44ecce7968c53e66 (diff) | |
| download | ansible-feature_threaded_queue.tar.gz | |
Move queuing tasks to a background threadfeature_threaded_queue
Diffstat (limited to 'lib/ansible/plugins/strategy/linear.py')
| -rw-r--r-- | lib/ansible/plugins/strategy/linear.py | 7 |
1 files changed, 6 insertions, 1 deletions
diff --git a/lib/ansible/plugins/strategy/linear.py b/lib/ansible/plugins/strategy/linear.py index 3f273606e2..1845e583da 100644 --- a/lib/ansible/plugins/strategy/linear.py +++ b/lib/ansible/plugins/strategy/linear.py @@ -181,7 +181,9 @@ class StrategyModule(StrategyBase): any_errors_fatal = False results = [] + items_to_queue = [] for (host, task) in host_tasks: + if not task: continue @@ -252,7 +254,8 @@ class StrategyModule(StrategyBase): display.debug("sending task start callback") self._blocked_hosts[host.get_name()] = True - self._queue_task(host, task, task_vars, play_context) + #self._queue_task(host, task, task_vars, play_context) + items_to_queue.append((host, task, task_vars)) del task_vars # if we're bypassing the host loop, break out now @@ -261,6 +264,8 @@ class StrategyModule(StrategyBase): results += self._process_pending_results(iterator, one_pass=True) + self._tqm.queue_multiple_tasks(items_to_queue, play_context) + # go to next host/task group if skip_rest: continue |