linting and formatting

Author: erwin-wee

chainbench/main.py

@@ -8,7 +8,6 @@
 import click
 import gevent.pool
 from click import Context, Parameter
-from gevent.libev.corecext import callback
 from locust.argument_parser import parse_locustfile_paths
 from locust.util.load_locustfile import load_locustfile
 

chainbench/test_data/blockchain.py

@@ -180,8 +180,7 @@ def _get_start_and_end_blocks(self, parsed_options: Namespace) -> BlockRange:
             self.start_block_number = 1
         if parsed_options.end_block is not None:
             self.end_block_number = parsed_options.end_block
-        return self._data.block_range
-
+        return self.data.block_range
 
     def get_block_from_data(self, data: dict[str, t.Any] | str) -> B:
         raise NotImplementedError
@@ -229,6 +228,7 @@ def end_block_number(self) -> BlockNumber:
     def end_block_number(self, value: BlockNumber) -> None:
         self.data.block_range.end = value
 
+
 class SmartContract:
     def __init__(self, address: str):
         self.address = address

chainbench/test_data/ethereum.py

@@ -139,7 +139,7 @@ def _get_start_and_end_blocks(self, parsed_options: Namespace) -> BlockRange:
             self.end_block_number = self.fetch_latest_block_number()
             self.start_block_number = self.end_block_number - self.data.size.blocks_len + 1
         logger.info("Using blocks from %s to %s as test data", self.start_block_number, self.end_block_number)
-        return self._data.block_range
+        return self.data.block_range
 
     def get_block_from_data(self, data: dict[str, t.Any] | str) -> EthBeaconBlock:
         def get_committee(committee: dict[str, t.Any]) -> EthCommittee:

chainbench/test_data/evm.py

@@ -495,15 +495,16 @@ def _get_start_and_end_blocks(self, parsed_options: Namespace) -> BlockRange:
             self.end_block_number = latest_block_number
             self.start_block_number = self.end_block_number - self.data.size.blocks_len + 1
         if self.start_block_number < 0:
-            logger.warning("start_block is before genesis block,"
-                           "setting to 0.")
+            logger.warning("start_block is before genesis block," "setting to 0.")
             self.start_block_number = 0
         if self.end_block_number > latest_block_number:
-            logger.warning(f"end_block {self.end_block_number} is after latest_block_number {latest_block_number},"
-                           "setting to latest_block_number.")
+            logger.warning(
+                f"end_block {self.end_block_number} is after latest_block_number {latest_block_number},"
+                "setting to latest_block_number."
+            )
             self.end_block_number = latest_block_number
         logger.info("Using blocks from %s to %s as test data", self.start_block_number, self.end_block_number)
-        return self._data.block_range
+        return self.data.block_range
 
     def get_random_block_hash(self, rng: RNG | None = None) -> BlockHash:
         if rng is None:

chainbench/test_data/solana.py

@@ -108,14 +108,14 @@ def _get_start_and_end_blocks(self, parsed_options: Namespace) -> BlockRange:
             self.end_block_number = latest_block_number
             self.start_block_number = self.end_block_number - self.data.size.blocks_len + 1
         if self.start_block_number < earliest_available_block_number:
-            logger.warning("start_block is before earliest_available_block_number,"
-                           "setting to earliest_available_block_number.")
+            logger.warning(
+                "start_block is before earliest_available_block_number," "setting to earliest_available_block_number."
+            )
             self.start_block_number = earliest_available_block_number
         if self.end_block_number > latest_block_number:
-            logger.warning("end_block is after latest_block_number,"
-                           "setting to latest_block_number.")
+            logger.warning("end_block is after latest_block_number," "setting to latest_block_number.")
             self.end_block_number = latest_block_number
-        return self._data.block_range
+        return self.data.block_range
 
     def get_random_block_hash(self, rng: RNG | None = None) -> BlockHash:
         if rng is None:

chainbench/util/event.py

@@ -72,6 +72,7 @@ def cli_custom_arguments(parser: LocustArgumentParser):
         include_in_web_ui=False,
     )
 
+
 def send_msg_to_workers(master_runner: MasterRunner, msg_type: str, data: dict[str, t.Any]):
     for i, worker in enumerate(master_runner.clients):
         master_runner.send_message(msg_type, {"data": (data, i)}, worker)

pyproject.toml

@@ -46,7 +46,7 @@ profile = "black"
 
 [tool.flake8]
 max-line-length = 120
-extend-ignore = ['E203']
+extend-ignore = ['E203', 'W503']
 
 [tool.black]
 line-length = 120