mirror of
https://github.com/xcat2/confluent.git
synced 2025-08-23 11:40:26 +00:00
Fix node collection notification code
This commit is contained in:
@@ -975,7 +975,7 @@ class ConfigManager(object):
|
||||
if newnodes:
|
||||
if self.tenant in self._nodecollwatchers:
|
||||
nodecollwatchers = self._nodecollwatchers[self.tenant]
|
||||
for watcher in nodecollwatchers[self.tenant].itervalues():
|
||||
for watcher in nodecollwatchers.itervalues():
|
||||
watcher(added=newnodes, deleting=[], configmanager=self)
|
||||
self._bg_sync_to_file()
|
||||
#TODO: wait for synchronization to suceed/fail??)
|
||||
|
Reference in New Issue
Block a user