Ruff

Author: thewhaleking

async_substrate_interface/async_substrate.py

@@ -1965,7 +1965,10 @@ def convert_event_data(data):
             block_hash = await self.get_chain_head()
 
         storage_obj = await self.query(
-            module="System", storage_function="Events", block_hash=block_hash, force_legacy_decode=True
+            module="System",
+            storage_function="Events",
+            block_hash=block_hash,
+            force_legacy_decode=True,
         )
         # bt-decode Metadata V15 is not ideal for events. Force legacy decoding for this
         if storage_obj:
@@ -2178,7 +2181,7 @@ async def _process_response(
         storage_item: Optional[ScaleType] = None,
         result_handler: Optional[ResultHandler] = None,
         runtime: Optional[Runtime] = None,
-        force_legacy_decode: bool = False
+        force_legacy_decode: bool = False,
     ) -> tuple[Any, bool]:
         """
         Processes the RPC call response by decoding it, returning it as is, or setting a handler for subscriptions,
@@ -2213,7 +2216,9 @@ async def _process_response(
                 q = bytes(query_value)
             else:
                 q = query_value
-            result = await self.decode_scale(value_scale_type, q, runtime=runtime, force_legacy=force_legacy_decode)
+            result = await self.decode_scale(
+                value_scale_type, q, runtime=runtime, force_legacy=force_legacy_decode
+            )
         if asyncio.iscoroutinefunction(result_handler):
             # For multipart responses as a result of subscriptions.
             message, bool_result = await result_handler(result, subscription_id)
@@ -2228,7 +2233,7 @@ async def _make_rpc_request(
         result_handler: Optional[ResultHandler] = None,
         attempt: int = 1,
         runtime: Optional[Runtime] = None,
-        force_legacy_decode: bool = False
+        force_legacy_decode: bool = False,
     ) -> RequestManager.RequestResults:
         request_manager = RequestManager(payloads)
 
@@ -2273,7 +2278,7 @@ async def _make_rpc_request(
                                 storage_item,
                                 result_handler,
                                 runtime=runtime,
-                                force_legacy_decode=force_legacy_decode
+                                force_legacy_decode=force_legacy_decode,
                             )
 
                             request_manager.add_response(
@@ -2305,7 +2310,7 @@ async def _make_rpc_request(
                             storage_item,
                             result_handler,
                             attempt + 1,
-                            force_legacy_decode
+                            force_legacy_decode,
                         )
 
         return request_manager.get_results()
@@ -3331,7 +3336,7 @@ async def query(
         subscription_handler=None,
         reuse_block_hash: bool = False,
         runtime: Optional[Runtime] = None,
-        force_legacy_decode: bool = False
+        force_legacy_decode: bool = False,
     ) -> Optional[Union["ScaleObj", Any]]:
         """
         Queries substrate. This should only be used when making a single request. For multiple requests,
@@ -3364,7 +3369,7 @@ async def query(
             storage_item,
             result_handler=subscription_handler,
             runtime=runtime,
-            force_legacy_decode=force_legacy_decode
+            force_legacy_decode=force_legacy_decode,
         )
         result = responses[preprocessed.queryable][0]
         if isinstance(result, (list, tuple, int, float)):

async_substrate_interface/sync_substrate.py

@@ -1634,7 +1634,10 @@ def convert_event_data(data):
             block_hash = self.get_chain_head()
 
         storage_obj = self.query(
-            module="System", storage_function="Events", block_hash=block_hash, force_legacy_decode=True
+            module="System",
+            storage_function="Events",
+            block_hash=block_hash,
+            force_legacy_decode=True,
         )
         # bt-decode Metadata V15 is not ideal for events. Force legacy decoding for this
         if storage_obj:
@@ -1821,7 +1824,7 @@ def _process_response(
         value_scale_type: Optional[str] = None,
         storage_item: Optional[ScaleType] = None,
         result_handler: Optional[ResultHandler] = None,
-        force_legacy_decode: bool = False
+        force_legacy_decode: bool = False,
     ) -> tuple[Any, bool]:
         """
         Processes the RPC call response by decoding it, returning it as is, or setting a handler for subscriptions,
@@ -1855,7 +1858,9 @@ def _process_response(
                 q = bytes(query_value)
             else:
                 q = query_value
-            result = self.decode_scale(value_scale_type, q, force_legacy=force_legacy_decode)
+            result = self.decode_scale(
+                value_scale_type, q, force_legacy=force_legacy_decode
+            )
         if isinstance(result_handler, Callable):
             # For multipart responses as a result of subscriptions.
             message, bool_result = result_handler(result, subscription_id)
@@ -1869,7 +1874,7 @@ def _make_rpc_request(
         storage_item: Optional[ScaleType] = None,
         result_handler: Optional[ResultHandler] = None,
         attempt: int = 1,
-        force_legacy_decode: bool = False
+        force_legacy_decode: bool = False,
     ) -> RequestManager.RequestResults:
         request_manager = RequestManager(payloads)
         _received = {}
@@ -1903,7 +1908,7 @@ def _make_rpc_request(
                         storage_item,
                         result_handler,
                         attempt + 1,
-                        force_legacy_decode
+                        force_legacy_decode,
                     )
             if "id" in response:
                 _received[response["id"]] = response
@@ -1935,7 +1940,7 @@ def _make_rpc_request(
                             value_scale_type,
                             storage_item,
                             result_handler,
-                            force_legacy_decode
+                            force_legacy_decode,
                         )
                         request_manager.add_response(
                             item_id, decoded_response, complete
@@ -2874,7 +2879,7 @@ def query(
         raw_storage_key: Optional[bytes] = None,
         subscription_handler=None,
         reuse_block_hash: bool = False,
-        force_legacy_decode: bool = False
+        force_legacy_decode: bool = False,
     ) -> Optional[Union["ScaleObj", Any]]:
         """
         Queries substrate. This should only be used when making a single request. For multiple requests,
@@ -2900,7 +2905,7 @@ def query(
             value_scale_type,
             storage_item,
             result_handler=subscription_handler,
-            force_legacy_decode=force_legacy_decode
+            force_legacy_decode=force_legacy_decode,
         )
         result = responses[preprocessed.queryable][0]
         if isinstance(result, (list, tuple, int, float)):