Merge "Fix missing node state refresh in static driver"

This commit is contained in:
Zuul 2018-09-07 14:35:55 +00:00 committed by Gerrit Code Review
commit 0b7cdbc45b
1 changed files with 5 additions and 1 deletions

View File

@ -197,7 +197,11 @@ class StaticNodeProvider(Provider):
# It's already locked so skip it.
continue
if node.state != zk.READY:
# Double check the state now that we have a lock since it
# may have changed on us. We keep using the original node
# since it's holding the lock.
_node = self.zk.getNode(node.id)
if _node.state != zk.READY:
# State changed so skip it.
self.zk.unlockNode(node)
continue