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

Revert "fix cache 'update' method to be 'mapping' compatible"

This reverts commit 68301f890a.
This commit is contained in:
Toshio Kuratomi 2018-12-04 11:18:46 -08:00
parent e4a3e73b15
commit d06cd869b8
3 changed files with 19 additions and 28 deletions

View file

@ -1,2 +0,0 @@
bugfixes:
- fix issue with incorrect dict update in vars manager

View file

@ -289,18 +289,10 @@ class FactCache(MutableMapping):
""" Flush the fact cache of all keys. """ """ Flush the fact cache of all keys. """
self._plugin.flush() self._plugin.flush()
def update(self, host_facts): def update(self, key, value):
""" We override the normal update to ensure we always use the 'setter' method """ host_cache = self._plugin.get(key)
for key in host_facts: host_cache.update(value)
try: self._plugin.set(key, host_cache)
host_cache = self._plugin.get(key)
if host_cache:
host_cache.update(host_facts[key])
else:
host_cache = host_facts[key]
self._plugin.set(key, host_cache)
except KeyError:
self._plugin.set(key, host_facts[key])
class InventoryFileCacheModule(BaseFileCacheModule): class InventoryFileCacheModule(BaseFileCacheModule):
@ -319,7 +311,7 @@ class InventoryFileCacheModule(BaseFileCacheModule):
def validate_cache_connection(self): def validate_cache_connection(self):
try: try:
super(InventoryFileCacheModule, self).validate_cache_connection() super(InventoryFileCacheModule, self).validate_cache_connection()
except AnsibleError: except AnsibleError as e:
cache_connection_set = False cache_connection_set = False
else: else:
cache_connection_set = True cache_connection_set = True

View file

@ -622,7 +622,8 @@ class VariableManager:
''' '''
Clears the facts for a host Clears the facts for a host
''' '''
self._fact_cache.pop(hostname, None) if hostname in self._fact_cache:
del self._fact_cache[hostname]
def set_host_facts(self, host, facts): def set_host_facts(self, host, facts):
''' '''
@ -632,16 +633,13 @@ class VariableManager:
if not isinstance(facts, dict): if not isinstance(facts, dict):
raise AnsibleAssertionError("the type of 'facts' to set for host_facts should be a dict but is a %s" % type(facts)) raise AnsibleAssertionError("the type of 'facts' to set for host_facts should be a dict but is a %s" % type(facts))
try: if host.name not in self._fact_cache:
try:
# this is a cache plugin, not a dictionary
self._fact_cache.update({host.name: facts})
except TypeError:
# this is here for backwards compatibilty for the time cache plugins were not 'dict compatible'
self._fact_cache.update(host.name, facts)
display.deprecated("Your configured fact cache plugin is using a deprecated form of the 'update' method", version="2.12")
except KeyError:
self._fact_cache[host.name] = facts self._fact_cache[host.name] = facts
else:
try:
self._fact_cache.update(host.name, facts)
except KeyError:
self._fact_cache[host.name] = facts
def set_nonpersistent_facts(self, host, facts): def set_nonpersistent_facts(self, host, facts):
''' '''
@ -651,10 +649,13 @@ class VariableManager:
if not isinstance(facts, dict): if not isinstance(facts, dict):
raise AnsibleAssertionError("the type of 'facts' to set for nonpersistent_facts should be a dict but is a %s" % type(facts)) raise AnsibleAssertionError("the type of 'facts' to set for nonpersistent_facts should be a dict but is a %s" % type(facts))
try: if host.name not in self._nonpersistent_fact_cache:
self._nonpersistent_fact_cache[host.name].update(facts)
except KeyError:
self._nonpersistent_fact_cache[host.name] = facts self._nonpersistent_fact_cache[host.name] = facts
else:
try:
self._nonpersistent_fact_cache[host.name].update(facts)
except KeyError:
self._nonpersistent_fact_cache[host.name] = facts
def set_host_variable(self, host, varname, value): def set_host_variable(self, host, varname, value):
''' '''