|
|
@ -155,7 +155,7 @@ class StrategyBase:
|
|
|
|
while not self._final_q.empty() and not self._tqm._terminated:
|
|
|
|
while not self._final_q.empty() and not self._tqm._terminated:
|
|
|
|
try:
|
|
|
|
try:
|
|
|
|
result = self._final_q.get(block=False)
|
|
|
|
result = self._final_q.get(block=False)
|
|
|
|
debug("got result from result worker: %s" % (result,))
|
|
|
|
debug("got result from result worker: %s" % ([unicode(x) for x in result],))
|
|
|
|
|
|
|
|
|
|
|
|
# all host status messages contain 2 entries: (msg, task_result)
|
|
|
|
# all host status messages contain 2 entries: (msg, task_result)
|
|
|
|
if result[0] in ('host_task_ok', 'host_task_failed', 'host_task_skipped', 'host_unreachable'):
|
|
|
|
if result[0] in ('host_task_ok', 'host_task_failed', 'host_task_skipped', 'host_unreachable'):
|
|
|
|