Merge branch 'devel' of https://github.com/andreyshestakov/ansible in…

…to andreyshestakov-devel
bigjools · Jun 6, 2016 · b9e743b · b9e743b
2 parents 560532d + 295c7ce
commit b9e743b
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 4 deletions.
diff --git a/lib/ansible/executor/process/result.py b/lib/ansible/executor/process/result.py
@@ -106,7 +106,7 @@ def run(self):
             try:
                 result = self._read_worker_result()
                 if result is None:
-                    time.sleep(0.0001)
+                    time.sleep(0.01)
                     continue
 
                 # send callbacks for 'non final' results

diff --git a/lib/ansible/plugins/strategy/__init__.py b/lib/ansible/plugins/strategy/__init__.py
@@ -196,7 +196,7 @@ def _queue_task(self, host, task, task_vars, play_context):
                 self._cur_worker += 1
                 if self._cur_worker >= len(self._workers):
                     self._cur_worker = 0
-                    time.sleep(0.0001)
+                    time.sleep(0.01)
                 if queued:
                     break
 
@@ -389,7 +389,7 @@ def get_original_host(host):
                     raise AnsibleError("unknown result message received: %s" % result[0])
 
             except Queue.Empty:
-                time.sleep(0.0001)
+                time.sleep(0.01)
 
             if one_pass:
                 break
@@ -408,7 +408,7 @@ def _wait_on_pending_results(self, iterator):
         while self._pending_results > 0 and not self._tqm._terminated:
             results = self._process_pending_results(iterator)
             ret_results.extend(results)
-            time.sleep(0.0001)
+            time.sleep(0.01)
         display.debug("no more pending results, returning what we have")
 
         return ret_results