From 44a20f12a4275ad0a3706c4740c6b11b4bd33949 Mon Sep 17 00:00:00 2001 From: Alexander Kukushkin Date: Mon, 14 Sep 2015 16:32:45 +0200 Subject: [PATCH] version field is znode is just version, not mzxid --- patroni/zookeeper.py | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/patroni/zookeeper.py b/patroni/zookeeper.py index 708cbafa..9e4ec8d8 100644 --- a/patroni/zookeeper.py +++ b/patroni/zookeeper.py @@ -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: