|
|
@ -587,13 +587,13 @@ class TaskExecutor:
|
|
|
|
# have issues which result in a half-written/unparseable result
|
|
|
|
# have issues which result in a half-written/unparseable result
|
|
|
|
# file on disk, which manifests to the user as a timeout happening
|
|
|
|
# file on disk, which manifests to the user as a timeout happening
|
|
|
|
# before it's time to timeout.
|
|
|
|
# before it's time to timeout.
|
|
|
|
if int(async_result.get('finished', 0)) == 1 or ('failed' in async_result and async_result.get('parsed', False)) or 'skipped' in async_result:
|
|
|
|
if int(async_result.get('finished', 0)) == 1 or ('failed' in async_result and async_result.get('_ansible_parsed', False)) or 'skipped' in async_result:
|
|
|
|
break
|
|
|
|
break
|
|
|
|
|
|
|
|
|
|
|
|
time_left -= self._task.poll
|
|
|
|
time_left -= self._task.poll
|
|
|
|
|
|
|
|
|
|
|
|
if int(async_result.get('finished', 0)) != 1:
|
|
|
|
if int(async_result.get('finished', 0)) != 1:
|
|
|
|
if async_result.get('parsed'):
|
|
|
|
if async_result.get('_ansible_parsed'):
|
|
|
|
return dict(failed=True, msg="async task did not complete within the requested time")
|
|
|
|
return dict(failed=True, msg="async task did not complete within the requested time")
|
|
|
|
else:
|
|
|
|
else:
|
|
|
|
return dict(failed=True, msg="async task produced unparseable results", async_result=async_result)
|
|
|
|
return dict(failed=True, msg="async task produced unparseable results", async_result=async_result)
|
|
|
|