Ruff

Author: thewhaleking

async_substrate_interface/async_substrate.py

@@ -2376,7 +2376,9 @@ async def _make_rpc_request(
             for payload in payloads:
                 item_id = await ws.send(payload["payload"])
                 request_manager.add_request(item_id, payload["id"])
-                logger.debug(f"Submitted payload ID {payload['id']} with websocket ID {item_id}: {payload}")
+                logger.debug(
+                    f"Submitted payload ID {payload['id']} with websocket ID {item_id}: {payload}"
+                )
 
             while True:
                 for item_id in request_manager.unresponded():
@@ -2417,11 +2419,16 @@ async def _make_rpc_request(
                             request_manager.add_response(
                                 item_id, decoded_response, complete
                             )
-                            if len(stringified_response := str(decoded_response)) < 2_000:
+                            if (
+                                len(stringified_response := str(decoded_response))
+                                < 2_000
+                            ):
                                 output_response = stringified_response
                                 # avoids clogging logs up needlessly (esp for Metadata stuff)
                             else:
-                                output_response = f"{stringified_response[:2_000]} (truncated)"
+                                output_response = (
+                                    f"{stringified_response[:2_000]} (truncated)"
+                                )
                             logger.debug(
                                 f"Received response for item ID {item_id}:\n{output_response}\n"
                                 f"Complete: {complete}"

async_substrate_interface/sync_substrate.py

@@ -1904,7 +1904,9 @@ def _make_rpc_request(
                 raw_websocket_logger.debug(f"WEBSOCKET_SEND> {to_send}")
             ws.send(json.dumps(to_send))
             request_manager.add_request(item_id, payload["id"])
-            logger.debug(f"Submitted payload ID {payload['id']} with websocket ID {item_id}: {payload}")
+            logger.debug(
+                f"Submitted payload ID {payload['id']} with websocket ID {item_id}: {payload}"
+            )
 
         while True:
             try:
@@ -1970,7 +1972,9 @@ def _make_rpc_request(
                             output_response = stringified_response
                             # avoids clogging logs up needlessly (esp for Metadata stuff)
                         else:
-                            output_response = f"{stringified_response[:2_000]} (truncated)"
+                            output_response = (
+                                f"{stringified_response[:2_000]} (truncated)"
+                            )
                         logger.debug(
                             f"Received response for item ID {item_id}:\n{output_response}\n"
                             f"Complete: {complete}"