gitops/patroni
1
0
Fork 0
mirror of https://github.com/outbackdingo/patroni.git synced 2026-08-25 14:53:37 +00:00
Code Issues Packages Projects Releases Wiki Activity

version field is znode is just version, not mzxid

Browse Source
This commit is contained in:
Alexander Kukushkin
2015-09-14 16:32:45 +02:00
parent bf5737614d
commit 44a20f12a4
1 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files
patroni/zookeeper.py
+3 -3
View File
@@ -115,7 +115,7 @@ class ZooKeeper(AbstractDCS):
@staticmethod
def member(name, value, znode):
conn_url, api_url = parse_connection_string(value)
return Member(znode.mzxid, name, conn_url, api_url, None, None)
return Member(znode.version, name, conn_url, api_url, None, None)
def get_children(self, key, watch=None):
try:
@@ -153,7 +153,7 @@ class ZooKeeper(AbstractDCS):
if leader:
member = Member(-1, leader[0], None, None, None, None)
member = ([m for m in members if m.name == leader[0]] or [member])[0]
leader = Leader(leader[1].mzxid, None, None, member)
leader = Leader(leader[1].version, None, None, member)
self.fetch_cluster = member.index == -1
# get last leader operation
@@ -231,7 +231,7 @@ class ZooKeeper(AbstractDCS):
def _cancel_initialization(self):
node = self.get_node(self.initialize_path)
if node and node[0] == self._name:
self.client.delete(self.initialize_path, version=node[1].mzxid)
self.client.delete(self.initialize_path, version=node[1].version)
def cancel_initialization(self):
try: