Add allow reconnect for all etcd clients

TuxEatPi · Sep 4, 2017 · 8be9d0a · 8be9d0a
1 parent c1f9e08
commit 8be9d0a
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/tuxeatpi_common/etcd_client.py b/tuxeatpi_common/etcd_client.py
@@ -37,7 +37,7 @@ def _connect(self):
         # Get sync client receiver
         while True:
             try:
-                etcd_client = etcd.Client(self.host, self.port)
+                etcd_client = etcd.Client(self.host, self.port, allow_reconnect=True)
                 # Test connection
                 etcd_client.cluster_version  # pylint: disable=W0104
                 # Save client
@@ -49,7 +49,7 @@ def _connect(self):
         # Get sync client sender
         while True:
             try:
-                etcd_sender = etcd.Client(self.host, self.port)
+                etcd_sender = etcd.Client(self.host, self.port, allow_reconnect=True)
                 # Test connection
                 etcd_sender.cluster_version  # pylint: disable=W0104
                 # Save client
@@ -59,7 +59,7 @@ def _connect(self):
                 self.logger.warning("Can not connect to etcd server, retrying in 5 seconds")
                 time.sleep(5)
         # Get async etcd client
-        self.async_client = aio_etcd.Client(self.host, self.port)
+        self.async_client = aio_etcd.Client(self.host, self.port, allow_reconnect=True)
 
     def read(self, key, recursive=False, wait=False, timeout=60):
         """Sync Etcd read operation"""