2
0
mirror of https://github.com/xcat2/confluent.git synced 2024-11-26 03:19:48 +00:00

Handle collective.manager being set back to the node

This commit is contained in:
Jarrod Johnson 2018-05-31 16:16:03 -04:00
parent 22b63df036
commit 867dd0dda7

View File

@ -237,6 +237,8 @@ class ConsoleHandler(object):
# Do not do console connect for nodes managed by another
# confluent collective member
self._is_local = False
else:
self._is_local = True
def get_buffer_age(self):
"""Return age of buffered data