Merge "Stop logging versions on every agent update"
This commit is contained in:
commit
bd4bae90a5
|
@ -144,6 +144,9 @@ class ResourceConsumerTracker(object):
|
|||
self._versions_by_consumer[consumer].keys())
|
||||
cur_resource_types = set(versions.keys())
|
||||
removed_resource_types = prev_resource_types - cur_resource_types
|
||||
if removed_resource_types:
|
||||
LOG.debug("Removing stale tracked versions: %s",
|
||||
removed_resource_types)
|
||||
for resource_type in removed_resource_types:
|
||||
self._set_version(consumer, resource_type, None)
|
||||
|
||||
|
@ -151,6 +154,7 @@ class ResourceConsumerTracker(object):
|
|||
"""Handle consumers reporting no versions."""
|
||||
if self._versions_by_consumer[consumer]:
|
||||
self._needs_recalculation = True
|
||||
LOG.debug("Clearing versions for consumer %s", consumer)
|
||||
self._versions_by_consumer[consumer] = {}
|
||||
|
||||
def get_resource_versions(self, resource_type):
|
||||
|
|
|
@ -400,9 +400,6 @@ class AgentDbMixin(ext_agent.AgentPluginBase, AgentAvailabilityZoneMixin):
|
|||
resource_versions = agent.get('resource_versions', {})
|
||||
consumer = version_manager.AgentConsumer(
|
||||
agent_type=agent['agent_type'], host=agent['host'])
|
||||
LOG.debug("Update consumer %(consumer)s versions to: "
|
||||
"%(versions)s", {'consumer': consumer,
|
||||
'versions': resource_versions})
|
||||
tracker.set_versions(consumer, resource_versions)
|
||||
|
||||
|
||||
|
|
Loading…
Reference in New Issue