Merge branch 'andreyshestakov-devel' into devel

pull/12806/merge
James Cammarata 8 years ago
commit b33aeee2f0

@ -106,7 +106,7 @@ class ResultProcess(multiprocessing.Process):
try: try:
result = self._read_worker_result() result = self._read_worker_result()
if result is None: if result is None:
time.sleep(0.0001) time.sleep(0.005)
continue continue
# send callbacks for 'non final' results # send callbacks for 'non final' results

@ -196,7 +196,7 @@ class StrategyBase:
self._cur_worker += 1 self._cur_worker += 1
if self._cur_worker >= len(self._workers): if self._cur_worker >= len(self._workers):
self._cur_worker = 0 self._cur_worker = 0
time.sleep(0.0001) time.sleep(0.005)
if queued: if queued:
break break
@ -389,7 +389,7 @@ class StrategyBase:
raise AnsibleError("unknown result message received: %s" % result[0]) raise AnsibleError("unknown result message received: %s" % result[0])
except Queue.Empty: except Queue.Empty:
time.sleep(0.0001) time.sleep(0.005)
if one_pass: if one_pass:
break break
@ -408,7 +408,7 @@ class StrategyBase:
while self._pending_results > 0 and not self._tqm._terminated: while self._pending_results > 0 and not self._tqm._terminated:
results = self._process_pending_results(iterator) results = self._process_pending_results(iterator)
ret_results.extend(results) ret_results.extend(results)
time.sleep(0.0001) time.sleep(0.005)
display.debug("no more pending results, returning what we have") display.debug("no more pending results, returning what we have")
return ret_results return ret_results

Loading…
Cancel
Save