Use try when watching health value in NodeInstance

This commit is contained in:
Joshua Boniface 2023-03-07 09:53:01 -05:00
parent 0b583bfdaf
commit 2c3a3cdf52
1 changed files with 23 additions and 18 deletions

View File

@ -225,6 +225,8 @@ class NodeInstance(object):
)
self.flush_thread.start()
try:
@self.zkhandler.zk_conn.DataWatch(
self.zkhandler.schema.path("node.monitoring.health", self.name)
)
@ -247,6 +249,9 @@ class NodeInstance(object):
if data != self.health:
self.health = data
except Exception:
pass
@self.zkhandler.zk_conn.DataWatch(
self.zkhandler.schema.path("node.memory.free", self.name)
)