diff --git a/patroni/dcs/etcd.py b/patroni/dcs/etcd.py index ec510a04..185b1ae7 100644 --- a/patroni/dcs/etcd.py +++ b/patroni/dcs/etcd.py @@ -184,7 +184,7 @@ class AbstractEtcdClientWithFailover(etcd.Client): for base_uri in machines_cache: try: - machines = list(self._get_members(base_uri, **kwargs)) + machines = list(set(self._get_members(base_uri, **kwargs))) logger.debug("Retrieved list of machines: %s", machines) if machines: random.shuffle(machines)