Handle invisible asyncio timeout error

Author: namikmesic

src/collectors/cardano.py

@@ -38,6 +38,11 @@ async def _probe(self) -> results:
                 results.record_latency(self.url, await fetch_latency(websocket))
                 results.record_health(self.url, True)
                 results.record_block_height(self.url, await self._blockHeight(websocket))
+        except asyncio.exceptions.TimeoutError:
+            logger.error(
+                f"Timed out while trying to establish websocket connection. Current open_timeout value in config: {cfg.open_timeout}.",
+                url=self.stripped_url)
+            results.record_health(self.url, False)
         except Exception as exc:
             results.record_health(self.url, False)
             logger.error(f"{exc}", url=self.stripped_url)

src/collectors/conflux.py

@@ -46,6 +46,11 @@ async def _probe(self) -> results:
                 results.record_client_version(self.url, await self._cfx_clientVersion(websocket))
                 results.record_head_count(self.url, self.sub.head_counter)
                 results.record_disconnects(self.url, self.sub.disconnects)
+        except asyncio.exceptions.TimeoutError:
+            logger.error(
+                f"Timed out while trying to establish websocket connection. Current open_timeout value in config: {cfg.open_timeout}.",
+                url=self.stripped_url)
+            results.record_health(self.url, False)        
         except Exception as exc:
             results.record_health(self.url, False)
             logger.error(f"{exc}", url=self.stripped_url)

src/collectors/evm.py

@@ -47,6 +47,11 @@ async def _probe(self) -> results:
                 results.record_client_version(self.url, await self._web3_clientVersion(websocket))
                 results.record_head_count(self.url, self.sub.head_counter)
                 results.record_disconnects(self.url, self.sub.disconnects)
+        except asyncio.exceptions.TimeoutError:
+            logger.error(
+                f"Timed out while trying to establish websocket connection. Current open_timeout value in config: {cfg.open_timeout}.",
+                url=self.stripped_url)
+            results.record_health(self.url, False)
         except Exception as exc:
             results.record_health(self.url, False)
             logger.error(f"{exc}", url=self.stripped_url)

src/settings.py

@@ -21,29 +21,28 @@ def __init__(self, config_file_path: str, validation_file_path: str):
         try:
             self.open_timeout = self.configuration['connection_parameters']['open_timeout']
         except KeyError:
-            logger.info("connection_parameters.open_timeout not set, defaulting to 5")
             self.open_timeout = 5
+            logger.info(f"connection_parameters.open_timeout not set, defaulting to {self.open_timeout}")
         try:
             self.close_timeout = self.configuration['connection_parameters']['close_timeout']
         except KeyError:
-            logger.info("connection_parameters.close_timeout not set, defaulting to 1")
-            self.close_timeout = 1
+            self.close_timeout = 4
+            logger.info(f"connection_parameters.close_timeout not set, defaulting to {self.close_timeout}")
         try:
             self.response_timeout = self.configuration['connection_parameters']['response_timeout']
         except KeyError:
-            logger.info("connection_parameters.response_timeout not set, defaulting to 5")
             self.response_timeout = 5
+            logger.info(f"connection_parameters.response_timeout not set, defaulting to {self.response_timeout}")
         try:
             self.ping_interval = self.configuration['connection_parameters']['ping_interval']
         except KeyError:
-            logger.info("connection_parameters.ping_interval not set, defaulting to 10")
             self.ping_interval = 10
+            logger.info(f"connection_parameters.ping_interval not set, defaulting to {self.ping_interval}")
         try:
             self.ping_timeout = self.configuration['connection_parameters']['ping_timeout']
         except KeyError:
-            logger.info("connection_parameters.ping_timeout not set, defaulting to 5")
             self.ping_timeout = 4
-
+            logger.info(f"connection_parameters.ping_timeout not set, defaulting to {self.ping_timeout}")
     def _populate_chain_id_metadata(self):
         # Conditionally add chain_id based on the colelctor type to each rpc item.
         if self.configuration['collector'] not in ['cardano', 'solana', 'bitcoin', 'doge', 'filecoin', 'starkware']: