From bda2bedf48ddb75a5cffaf810a90e447ed753fc4 Mon Sep 17 00:00:00 2001 From: Alexander Kukushkin Date: Tue, 25 Oct 2022 14:14:16 +0200 Subject: [PATCH] Make sure self.__retry_timeout is set (#2440) The default value was None, which is the same as no timeout. --- patroni/dcs/raft.py | 5 ++--- 1 file changed, 2 insertions(+), 3 deletions(-) diff --git a/patroni/dcs/raft.py b/patroni/dcs/raft.py index f3af829f..9563f31c 100644 --- a/patroni/dcs/raft.py +++ b/patroni/dcs/raft.py @@ -97,7 +97,7 @@ class KVStoreTTL(DynMemberSyncObj): self.__on_set = on_set self.__on_delete = on_delete self.__limb = {} - self.__retry_timeout = None + self.set_retry_timeout(int(config.get('retry_timeout') or 10)) self_addr = config.get('self_addr') partner_addrs = set(config.get('partner_addrs', [])) @@ -121,8 +121,7 @@ class KVStoreTTL(DynMemberSyncObj): journalFile=(file_template + '.journal' if self_addr else None), onReady=on_ready, dynamicMembershipChange=True) - retry_timeout = int(config.get('retry_timeout') or 10) - super(KVStoreTTL, self).__init__(self_addr, partner_addrs, conf, retry_timeout) + super(KVStoreTTL, self).__init__(self_addr, partner_addrs, conf, self.__retry_timeout) self.__data = {} @staticmethod