logging

lbry/utils.py

@@ -231,7 +231,7 @@ class LRUCacheWithMetrics:
                     f"{metric_name}_cache_miss_count", "Number of cache misses", namespace=namespace
                 )
             except ValueError as err:
-                log.warning("failed to set up prometheus %s_cache_miss_count metric: %s", metric_name, err)
+                log.debug("failed to set up prometheus %s_cache_miss_count metric: %s", metric_name, err)
                 self._track_metrics = False
                 self.hits = self.misses = None
 

lbry/wallet/network.py

@@ -67,7 +67,7 @@ class ClientSession(BaseClientSession):
                     log.debug("Time since last packet: %s", perf_counter() - self.last_packet_received)
                     if (perf_counter() - self.last_packet_received) < self.timeout:
                         continue
-                    log.info("timeout sending %s to %s:%i", method, *self.server)
+                    log.warning("timeout sending %s to %s:%i", method, *self.server)
                     raise asyncio.TimeoutError
                 if done:
                     try:
@@ -87,7 +87,7 @@ class ClientSession(BaseClientSession):
             self.synchronous_close()
             raise
         except asyncio.CancelledError:
-            log.info("cancelled sending %s to %s:%i", method, *self.server)
+            log.warning("cancelled sending %s to %s:%i", method, *self.server)
             # self.synchronous_close()
             raise
         finally:
@@ -145,7 +145,7 @@ class ClientSession(BaseClientSession):
         controller.add(request.args)
 
     def connection_lost(self, exc):
-        log.debug("Connection lost: %s:%d", *self.server)
+        log.warning("Connection lost: %s:%d", *self.server)
         super().connection_lost(exc)
         self.response_time = None
         self.connection_latency = None

lbry/wallet/server/session.py

@@ -582,6 +582,7 @@ class SessionManager:
             ])
         finally:
             await self._close_servers(list(self.servers.keys()))
+            log.warning("disconnect %i sessions", len(self.sessions))
             if self.sessions:
                 await asyncio.wait([
                     session.close(force_after=1) for session in self.sessions.values()