unreachable delegation fix

pull/82470/head
Brian Coca 11 months ago
parent 55065c0042
commit fb917d96ad

@ -630,9 +630,17 @@ class StrategyBase:
elif task_result.is_unreachable():
ignore_unreachable = original_task.ignore_unreachable
if not ignore_unreachable:
self._tqm._unreachable_hosts[original_host.name] = True
iterator._play._removed_hosts.append(original_host.name)
self._tqm._stats.increment('dark', original_host.name)
delegated_host = result.get('ansible_delegated_host', None)
if original_task.delegate_to is not None and delegated_host:
self._tqm._unreachable_hosts[delegated_host] = True
iterator._play._removed_hosts.append(delegated_host)
if origianl_host.name not in self._tqm._unreachable_hosts:
iterator.mark_host_failed(original_host)
self._tqm._stats.increment('failures', original_host.name)
else:
self._tqm._unreachable_hosts[original_host.name] = True
iterator._play._removed_hosts.append(original_host.name)
self._tqm._stats.increment('dark', original_host.name)
else:
self._tqm._stats.increment('ok', original_host.name)
self._tqm._stats.increment('ignored', original_host.name)

Loading…
Cancel
Save