fix: linter

Author: vgorkavenko

src/constants.py

@@ -1,8 +1,6 @@
 from packaging.version import Version
 
 from src.types import Gwei
-from src.variables import STAKING_MODULE_ADDRESS
-
 # https://github.com/ethereum/consensus-specs/blob/dev/specs/phase0/beacon-chain.md#misc
 FAR_FUTURE_EPOCH = 2**64 - 1
 # https://github.com/ethereum/consensus-specs/blob/dev/specs/phase0/beacon-chain.md#time-parameters-1

src/main.py

@@ -12,7 +12,7 @@
 
 
 def main(module: OracleModule):
-    # pylint: disable=import-outside-toplevel
+    # pylint: disable=import-outside-toplevel,too-many-return-statements
 
     if module is OracleModule.CHECK:
         errors = variables.check_uri_required_variables()

src/modules/checks/suites/common.py

@@ -63,4 +63,3 @@ def check_csm_contract_configs(csm):
 def check_cm_contract_configs(cm):
     """Make sure cm contract configs are valid"""
     cm.check_contract_configs()
-

src/modules/oracles/common/oracle_module.py

@@ -49,6 +49,7 @@ def run_cycle(self, last_finalized_blockstamp: BlockStamp):
 
     @contextmanager
     def exception_handler(self) -> Iterator[None]:
+        # pylint: disable=too-many-branches
         """Context manager for handling Oracle module cycle exceptions"""
         try:
             yield
@@ -86,7 +87,6 @@ def exception_handler(self) -> Iterator[None]:
         except ValueError as error:
             logger.error({'msg': 'Unexpected error.', 'error': str(error)})
         except Exception as error:
-            # Перебрасываем неизвестные исключения
             raise error
 
     @abstractmethod

src/modules/oracles/staking_modules/base.py

@@ -1,6 +1,5 @@
 import atexit
 import logging
-from abc import abstractmethod
 
 from hexbytes import HexBytes
 
@@ -55,22 +54,17 @@ class SMPerformanceOracle(OracleModule):
         3. Calculate the share of each node operator excluding underperforming validators.
     """
 
-    @property
-    @abstractmethod
-    def COMPATIBLE_CONTRACT_VERSION(self) -> int:
-        """Contract version this oracle is compatible with"""
-        raise NotImplementedError
-
-    @property
-    @abstractmethod
-    def COMPATIBLE_CONSENSUS_VERSION(self) -> int:
-        """Consensus version this oracle is compatible with"""
-        raise NotImplementedError
+    COMPATIBLE_CONTRACT_VERSION: int = 0
+    COMPATIBLE_CONSENSUS_VERSION: int = 0
 
     report_contract: CSFeeOracleContract
     state: State
 
     def __init__(self, w3: Web3):
+        if self.COMPATIBLE_CONTRACT_VERSION == 0:
+            raise ValueError("CONTRACT_VERSION is not defined")
+        if self.COMPATIBLE_CONSENSUS_VERSION == 0:
+            raise ValueError("CONSENSUS_VERSION is not defined")
         self.consumer = self.__class__.__name__
         self.report_contract = w3.staking_module.oracle
         self.state = State.load(self.consumer)

src/modules/oracles/staking_modules/common/state.py

@@ -118,7 +118,8 @@ def load(cls, oracle_name: str) -> Self:
                 if not obj:
                     raise ValueError("Got empty object")
                 # Ensure loaded object has the correct oracle_name
-                if hasattr(obj, "_oracle_name") and obj._oracle_name != oracle_name:
+                # pylint: disable=protected-access
+                if obj._oracle_name != oracle_name:
                     logger.warning({
                         "msg": f"Cache oracle name mismatch: {obj._oracle_name} != {oracle_name}. Creating new state."
                     })

src/modules/sidecars/performance/collector/collector.py

@@ -60,7 +60,6 @@ def exception_handler(self) -> Iterator[None]:
         except ValueError as error:
             logger.error({'msg': 'Unexpected error.', 'error': str(error)})
         except Exception as error:
-            # Перебрасываем неизвестные исключения
             raise error
 
     def _build_converter(self) -> ChainConverter:

src/web3py/extensions/staking_module.py

@@ -161,4 +161,4 @@ def has_contract_address_changed(self) -> bool:
         return False
 
     def reload_contracts(self) -> None:
-        self._load_contracts()
+        self._load_contracts()

tests/fork/test_csm_oracle_cycle.py

@@ -100,16 +100,16 @@ def missed_initial_frame(frame_config: FrameConfig, cycle_iterations):
     'module',
     [
         csm_module,
-        #cm_module
+        # cm_module
     ],
     indirect=True,
 )
 @pytest.mark.parametrize(
     'running_finalized_slots',
     [
-        #start_before_initial_epoch,
+        # start_before_initial_epoch,
         start_after_initial_epoch,
-        #missed_initial_frame
+        # missed_initial_frame
     ],
     indirect=True,
 )

tests/modules/accounting/staking_vault/test_staking_vaults.py

@@ -2261,7 +2261,7 @@ def test_get_start_point_fresh_devnet_case(self):
 
         ipfs_data = OnChainIpfsVaultReportData(
             timestamp=1690000100, ref_slot=SlotNumber(1230), tree_root=b'\xab\xcd\xef', report_cid=""
-        )  # важно!
+        )  # Important!
 
         frame_config = FrameConfig(initial_epoch=10, epochs_per_frame=2, fast_lane_length_slots=16)