chore: fix formatting

Author: lla-dane

libp2p/metrics/bandwidth.py

@@ -1,4 +1,3 @@
-import asyncio
 from prometheus_client import Counter
 
 
@@ -8,7 +7,6 @@ class BandwidthMetrics:
     """
 
     def __init__(self):
-
         self.bandwidth = Counter(
             "libp2p_bandwidth_bytes_total",
             "Bandwidth usage by direction and protocol stack",
@@ -70,7 +68,6 @@ def __init__(self, transport, metrics: BandwidthMetrics):
         self.metrics = metrics
 
     async def dial(self, addr, protocols):
-
         stream = await self.transport.dial(addr)
 
         return InstrumentedStream(
@@ -80,11 +77,10 @@ async def dial(self, addr, protocols):
         )
 
     async def accept(self, protocols):
-
         stream = await self.transport.accept()
 
         return InstrumentedStream(
             stream,
             self.metrics,
             protocols,
-        )
+        )

libp2p/metrics/swarm.py

@@ -1,4 +1,5 @@
 import time
+
 from prometheus_client import Counter, Histogram
 
 
@@ -9,7 +10,6 @@ class SwarmMetrics:
     """
 
     def __init__(self):
-
         # ---------------------------
         # incoming connections
         # ---------------------------
@@ -40,19 +40,14 @@ def __init__(self):
             "swarm_connections_establishment_duration_seconds",
             "Time taken to establish connection",
             ["role", "protocols"],
-            buckets=(
-                0.01, 0.02, 0.05, 0.1,
-                0.2, 0.5, 1, 2, 5, 10
-            ),
+            buckets=(0.01, 0.02, 0.05, 0.1, 0.2, 0.5, 1, 2, 5, 10),
         )
 
         self.connections_duration = Histogram(
             "swarm_connections_duration_seconds",
             "Time a connection was alive",
             ["role", "protocols", "cause"],
-            buckets=(
-                0.01, 0.1, 1, 5, 10, 30, 60, 300, 600
-            ),
+            buckets=(0.01, 0.1, 1, 5, 10, 30, 60, 300, 600),
         )
 
         # ---------------------------
@@ -135,11 +130,9 @@ def record(self, event):
         """
         Record a SwarmEvent-like object.
         """
-
         etype = event["type"]
 
         if etype == "ConnectionEstablished":
-
             role = event["role"]
             protocols = event["protocols"]
             conn_id = event["connection_id"]
@@ -158,7 +151,6 @@ def record(self, event):
             self.connections[conn_id] = time.time()
 
         elif etype == "ConnectionClosed":
-
             conn_id = event["connection_id"]
             role = event["role"]
             protocols = event["protocols"]
@@ -174,65 +166,40 @@ def record(self, event):
                 ).observe(elapsed)
 
         elif etype == "IncomingConnection":
-
-            self.connections_incoming.labels(
-                protocols=event["protocols"]
-            ).inc()
+            self.connections_incoming.labels(protocols=event["protocols"]).inc()
 
         elif etype == "IncomingConnectionError":
-
             self.connections_incoming_error.labels(
                 error=event["error"],
                 protocols=event["protocols"],
             ).inc()
 
         elif etype == "OutgoingConnectionError":
-
             self.outgoing_connection_error.labels(
                 peer=event["peer"],
                 error=event["error"],
             ).inc()
 
         elif etype == "NewListenAddr":
-
-            self.new_listen_addr.labels(
-                protocols=event["protocols"]
-            ).inc()
+            self.new_listen_addr.labels(protocols=event["protocols"]).inc()
 
         elif etype == "ExpiredListenAddr":
-
-            self.expired_listen_addr.labels(
-                protocols=event["protocols"]
-            ).inc()
+            self.expired_listen_addr.labels(protocols=event["protocols"]).inc()
 
         elif etype == "ListenerClosed":
-
-            self.listener_closed.labels(
-                protocols=event["protocols"]
-            ).inc()
+            self.listener_closed.labels(protocols=event["protocols"]).inc()
 
         elif etype == "ListenerError":
-
             self.listener_error.inc()
 
         elif etype == "Dialing":
-
             self.dial_attempt.inc()
 
         elif etype == "NewExternalAddrCandidate":
-
-            self.external_addr_candidates.labels(
-                protocols=event["protocols"]
-            ).inc()
+            self.external_addr_candidates.labels(protocols=event["protocols"]).inc()
 
         elif etype == "ExternalAddrConfirmed":
-
-            self.external_addr_confirmed.labels(
-                protocols=event["protocols"]
-            ).inc()
+            self.external_addr_confirmed.labels(protocols=event["protocols"]).inc()
 
         elif etype == "ExternalAddrExpired":
-
-            self.external_addr_expired.labels(
-                protocols=event["protocols"]
-            ).inc()
+            self.external_addr_expired.labels(protocols=event["protocols"]).inc()