Reconnect aio_etcd_client on timeout

TuxEatPi · Sep 2, 2017 · 159624b · 159624b
1 parent 0fa3c47
commit 159624b
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/tuxeatpi_common/settings.py b/tuxeatpi_common/settings.py
@@ -66,6 +66,8 @@ async def read(self, watch=False):
                 self.logger.info("Component settings not found, waiting")
                 await asyncio.sleep(3)
                 continue
+            except asyncio.TimeoutError:
+                continue
             self.logger.info("Component settings received")
             self.params = json.loads(raw_data.value)  # pylint: disable=E1101
             self.component.set_config(config=self.params)
@@ -88,6 +90,8 @@ async def read_global(self, watch=False):
                 self.logger.info("Global settings not found, waiting")
                 await asyncio.sleep(3)
                 continue
+            except asyncio.TimeoutError:
+                continue
             self.logger.info("Global settings received")
             data = json.loads(raw_data.value)
             if data.get('language') != self.language: