Wait up to 30s to lock a node
Otherwise, we might wait indefinitely if something has gone wrong with zookeeper. Change-Id: I1f00beef34c72b3ebff7605fcc0e12ea3f3105dd
This commit is contained in:
parent
e2f0a87ad8
commit
ac1155d2b1
|
@ -117,7 +117,7 @@ class Nodepool(object):
|
||||||
try:
|
try:
|
||||||
for node in nodes:
|
for node in nodes:
|
||||||
self.log.debug("Locking node %s" % (node,))
|
self.log.debug("Locking node %s" % (node,))
|
||||||
self.sched.zk.lockNode(node)
|
self.sched.zk.lockNode(node, timeout=30)
|
||||||
locked_nodes.append(node)
|
locked_nodes.append(node)
|
||||||
except Exception:
|
except Exception:
|
||||||
self.log.exception("Error locking nodes:")
|
self.log.exception("Error locking nodes:")
|
||||||
|
|
Loading…
Reference in New Issue