ansible/community.general
1
0
Fork 0
mirror of https://github.com/ansible-collections/community.general.git synced 2024-09-14 20:13:21 +02:00
Code Releases Activity

template hostvars for set_host_overrides (#23839)

Browse source 
* fixes #23586
* temporary solution until connection-specific vars are handled by play_context
This commit is contained in:
Matt Davis 2017-04-20 20:33:48 -07:00 committed by GitHub
parent 79b9c585ea
commit 02ed223d49
1 changed files with 7 additions and 5 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

12
lib/ansible/executor/task_executor.py
View file

@ -31,6 +31,7 @@ from ansible.module_utils.six import iteritems, string_types, binary_type
from ansible.module_utils._text import to_text from ansible.module_utils._text import to_text
from ansible.playbook.conditional import Conditional from ansible.playbook.conditional import Conditional
from ansible.playbook.task import Task from ansible.playbook.task import Task
from ansible.plugins.connection import ConnectionBase
from ansible.template import Templar from ansible.template import Templar
from ansible.utils.encrypt import key_for_hostname from ansible.utils.encrypt import key_for_hostname
from ansible.utils.listify import listify_lookup_plugin_terms from ansible.utils.listify import listify_lookup_plugin_terms
@ -476,16 +477,17 @@ class TaskExecutor:
self._play_context.remote_addr != self._connection._play_context.remote_addr): self._play_context.remote_addr != self._connection._play_context.remote_addr):
self._connection = self._get_connection(variables=variables, templar=templar) self._connection = self._get_connection(variables=variables, templar=templar)
hostvars = variables.get('hostvars', None) hostvars = variables.get('hostvars', None)
if hostvars: # only template the vars if the connection actually implements set_host_overrides
# NB: this is expensive, and should be removed once connection-specific vars are being handled by play_context
sho_impl = getattr(type(self._connection), 'set_host_overrides', None)
if hostvars and sho_impl and sho_impl != ConnectionBase.set_host_overrides:
try: try:
target_hostvars = hostvars.raw_get(self._host.name) target_hostvars = hostvars.get(self._host.name)
except: except:
# FIXME: this should catch the j2undefined error here # FIXME: this should catch the j2undefined error here
# specifically instead of all exceptions # specifically instead of all exceptions
target_hostvars = dict() target_hostvars = dict()
else: self._connection.set_host_overrides(host=self._host, hostvars=target_hostvars)
target_hostvars = dict()
self._connection.set_host_overrides(host=self._host, hostvars=target_hostvars)
else: else:
# if connection is reused, its _play_context is no longer valid and needs # if connection is reused, its _play_context is no longer valid and needs
# to be replaced with the one templated above, in case other data changed # to be replaced with the one templated above, in case other data changed