pylint: Don't disable check for the whole file

Also use `disable-next` instead of disabling blocks, as it is less
error prone.

Signed-off-by: Leandro Lucarella <[email protected]>

Author: llucax

examples/battery_pool.py

@@ -33,9 +33,8 @@ async def main() -> None:
     receivers = [
         battery_pool.soc.new_receiver(limit=1),
         battery_pool.capacity.new_receiver(limit=1),
-        # pylint: disable=protected-access
+        # pylint: disable-next=protected-access
         battery_pool._system_power_bounds.new_receiver(limit=1),
-        # pylint: enable=protected-access
     ]
 
     async for metric in merge(*receivers):

src/frequenz/sdk/microgrid/_power_distributing/_component_status/_battery_status_tracker.py

@@ -394,8 +394,8 @@ def _is_inverter_state_correct(self, msg: InverterData) -> bool:
             True if inverter is in correct state. False otherwise.
         """
         # Component state is not exposed to the user.
-        # pylint: disable=protected-access
         state = msg.component_state
+        # pylint: disable-next=protected-access
         if state not in BatteryStatusTracker._inverter_valid_state:
             if self._last_status == ComponentStatusEnum.WORKING:
                 _logger.warning(
@@ -404,7 +404,6 @@ def _is_inverter_state_correct(self, msg: InverterData) -> bool:
                     state.name,
                 )
             return False
-        # pylint: enable=protected-access
         return True
 
     def _is_battery_state_correct(self, msg: BatteryData) -> bool:
@@ -417,8 +416,8 @@ def _is_battery_state_correct(self, msg: BatteryData) -> bool:
             True if battery is in correct state. False otherwise.
         """
         # Component state is not exposed to the user.
-        # pylint: disable=protected-access
         state = msg.component_state
+        # pylint: disable-next=protected-access
         if state not in BatteryStatusTracker._battery_valid_state:
             if self._last_status == ComponentStatusEnum.WORKING:
                 _logger.warning(
@@ -439,7 +438,6 @@ def _is_battery_state_correct(self, msg: BatteryData) -> bool:
                 )
             return False
         return True
-        # pylint: enable=protected-access
 
     def _is_timestamp_outdated(self, timestamp: datetime) -> bool:
         """Return if timestamp is to old.

src/frequenz/sdk/microgrid/_power_distributing/_distribution_algorithm/_battery_distribution_algorithm.py

@@ -461,7 +461,8 @@ def _compute_battery_availability_ratio(
 
         return battery_availability_ratio, total_battery_availability_ratio
 
-    def _distribute_power(  # pylint: disable=too-many-arguments
+    # pylint: disable-next=too-many-arguments,too-many-locals,too-many-branches,too-many-statements
+    def _distribute_power(
         self,
         *,
         components: list[InvBatPair],
@@ -470,7 +471,6 @@ def _distribute_power(  # pylint: disable=too-many-arguments
         incl_bounds: dict[ComponentId, Power],
         excl_bounds: dict[ComponentId, Power],
     ) -> DistributionResult:
-        # pylint: disable=too-many-locals,too-many-branches,too-many-statements
         """Distribute power between given components.
 
         After this method power should be distributed between batteries

src/frequenz/sdk/microgrid/_power_distributing/power_distributing.py

@@ -33,8 +33,7 @@
 _logger = logging.getLogger(__name__)
 
 
-class PowerDistributingActor(Actor):
-    # pylint: disable=too-many-instance-attributes
+class PowerDistributingActor(Actor):  # pylint: disable=too-many-instance-attributes
     """Actor to distribute the power between components in a microgrid.
 
     One instance of the actor can handle only one component category and type,

src/frequenz/sdk/microgrid/_power_managing/_power_managing_actor.py

@@ -158,16 +158,17 @@ def _add_system_bounds_tracker(self, component_ids: frozenset[ComponentId]) -> N
             NotImplementedError: When the pool type is not supported.
         """
         bounds_receiver: Receiver[SystemBounds]
-        # pylint: disable=protected-access
         if self._component_category is ComponentCategory.BATTERY:
             battery_pool = _data_pipeline.new_battery_pool(
                 priority=-sys.maxsize - 1, component_ids=component_ids
             )
+            # pylint: disable-next=protected-access
             bounds_receiver = battery_pool._system_power_bounds.new_receiver()
         elif self._component_category is ComponentCategory.EV_CHARGER:
             ev_charger_pool = _data_pipeline.new_ev_charger_pool(
                 priority=-sys.maxsize - 1, component_ids=component_ids
             )
+            # pylint: disable-next=protected-access
             bounds_receiver = ev_charger_pool._system_power_bounds.new_receiver()
         elif (
             self._component_category is ComponentCategory.INVERTER
@@ -176,8 +177,8 @@ def _add_system_bounds_tracker(self, component_ids: frozenset[ComponentId]) -> N
             pv_pool = _data_pipeline.new_pv_pool(
                 priority=-sys.maxsize - 1, component_ids=component_ids
             )
+            # pylint: disable-next=protected-access
             bounds_receiver = pv_pool._system_power_bounds.new_receiver()
-        # pylint: enable=protected-access
         else:
             err = (
                 "PowerManagingActor: Unsupported component category: "

src/frequenz/sdk/microgrid/_power_wrapper.py

@@ -9,14 +9,16 @@
 from datetime import timedelta
 
 from frequenz.channels import Broadcast
-
-# pylint seems to think this is a cyclic import, but it is not.
-#
-# pylint: disable=cyclic-import
 from frequenz.client.microgrid import ComponentCategory, ComponentType
 
 from .._internal._channels import ChannelRegistry, ReceiverFetcher
+
+# pylint seems to think this is a cyclic import, but it is not.
+#
+# pylint: disable-next=cyclic-import
 from . import _power_managing, connection_manager
+
+# pylint: disable-next=cyclic-import
 from ._power_distributing import (
     ComponentPoolStatus,
     PowerDistributingActor,

src/frequenz/sdk/timeseries/_resampling/_config.py

@@ -80,11 +80,10 @@ def __call__(
         ...  # pylint: disable=unnecessary-ellipsis
 
 
-# pylint: disable=unused-argument
 def average(
     samples: Sequence[Sample[QuantityT]],
-    resampler_config: ResamplerConfig,
-    source_properties: SourceProperties,
+    resampler_config: ResamplerConfig,  # pylint: disable=unused-argument
+    source_properties: SourceProperties,  # pylint: disable=unused-argument
 ) -> float:
     """Calculate average of all the provided values.
 

src/frequenz/sdk/timeseries/battery_pool/_component_metric_fetcher.py

@@ -104,15 +104,15 @@ async def async_new(
         """
         self: Self = await super().async_new(component_id, metrics)
 
+        # pylint: disable=protected-access
         for metric in metrics:
-            # pylint: disable=protected-access
             if metric not in self._supported_metrics():
                 category = self._component_category()
                 raise ValueError(f"Metric {metric} not supported for {category}")
 
-        # pylint: disable=protected-access
         self._receiver = await self._subscribe()
         self._max_waiting_time = MAX_BATTERY_DATA_AGE_SEC
+        # pylint: enable=protected-access
         return self
 
     async def fetch_next(self) -> ComponentMetricsData | None: