X-Git-Url: http://git.onelab.eu/?a=blobdiff_plain;f=nodecommon.py;h=2250492ad1e4eb9dcd1acffc50fa090679514457;hb=refs%2Fheads%2F1.0;hp=624ee2ca39a32da4f982603745619c3982b7b052;hpb=6df6b8cf9b9a5e78f4f68445e1b2dabc2ae272e6;p=monitor.git diff --git a/nodecommon.py b/nodecommon.py index 624ee2c..2250492 100644 --- a/nodecommon.py +++ b/nodecommon.py @@ -75,6 +75,7 @@ def color_boot_state(l): elif l == "down": return red(l) elif l == "boot": return green(l) elif l == "rins": return blue(l) + elif l == "reinstall": return blue(l) else: return l @@ -109,6 +110,16 @@ def diff_time(timestamp, abstime=True): t_str = "%s mnths ago" % int(t) return t_str +def getvalue(fb, path): + indexes = path.split("/") + values = fb + for index in indexes: + if index in values: + values = values[index] + else: + return None + return values + def nodegroup_display(node, fb, conf=None): if node['hostname'] in fb['nodes']: node['current'] = get_current_state(fb['nodes'][node['hostname']]['values']) @@ -172,7 +183,7 @@ def get_nodeset(config): f_nodes = [config.node] l_nodes = filter(lambda x: x['hostname'] in f_nodes, l_nodes) elif config.nodegroup: - ng = api.GetNodeGroups({'name' : config.nodegroup}) + ng = api.GetNodeGroups({'groupname' : config.nodegroup}) l_nodes = api.GetNodes(ng[0]['node_ids'], ['hostname']) elif config.site: site = api.GetSites(config.site) @@ -188,3 +199,13 @@ def get_nodeset(config): return l_nodes +def email_exception(content=None): + import config + from unified_model import Message + import traceback + msg=traceback.format_exc() + if content: + msg = content + "\n" + msg + m=Message("exception running monitor", msg, False) + m.send([config.cc_email]) + return