2
0
mirror of https://github.com/xcat2/confluent.git synced 2025-01-09 13:05:49 +00:00

Do not let a single node error stop all pending node

Isolate faults to single node for better robust behavior.
This commit is contained in:
Jarrod Johnson 2017-08-22 16:50:04 -04:00
parent b93a2e60d2
commit 2cdfa8fcae

View File

@ -366,8 +366,13 @@ def _recheck_nodes(nodeattribs, configmanager):
# policy or hadn't been able to verify key
for nodename in pending_nodes:
info = pending_nodes[nodename]
handler = info['handler'].NodeHandler(info, configmanager)
eventlet.spawn_n(eval_node, configmanager, handler, info, nodename)
try:
handler = info['handler'].NodeHandler(info, configmanager)
eventlet.spawn_n(eval_node, configmanager, handler, info, nodename)
except Exception:
traceback.print_exc()
log.log({'error': 'Unexpected error during discovery of {0}, check debug '
'logs'.format(nodename)})
def _recheck_single_unknown(configmanager, mac):