Use custom loggers for each module (#780)

Rather than using the global logging module.

Author: daniel-zullo-frequenz

src/frequenz/sdk/actor/_config_managing.py

@@ -74,7 +74,7 @@ def _read_config(self) -> dict[str, Any]:
             with self._config_path.open("rb") as toml_file:
                 return tomllib.load(toml_file)
         except ValueError as err:
-            logging.error("%s: Can't read config file, err: %s", self, err)
+            _logger.error("%s: Can't read config file, err: %s", self, err)
             raise
 
     async def send_config(self) -> None:

src/frequenz/sdk/timeseries/_grid_frequency.py

@@ -21,6 +21,8 @@
     # Imported here to avoid a circular import.
     from ..actor import ComponentMetricRequest
 
+_logger = logging.getLogger(__name__)
+
 
 def create_request(component_id: int) -> ComponentMetricRequest:
     """Create a request for grid frequency.
@@ -87,15 +89,15 @@ def new_receiver(self) -> Receiver[Sample[Frequency]]:
         if not self._task:
             self._task = asyncio.create_task(self._send_request())
         else:
-            logging.info("Grid frequency request already sent: %s", self._component)
+            _logger.info("Grid frequency request already sent: %s", self._component)
 
         return receiver
 
     async def _send_request(self) -> None:
         """Send the request for grid frequency."""
-        logging.info("Sending request for grid frequency: %s", self._component)
+        _logger.info("Sending request for grid frequency: %s", self._component)
         await self._request_sender.send(self._component_metric_request)
-        logging.info("Sent request for grid frequency: %s", self._component)
+        _logger.info("Sent request for grid frequency: %s", self._component)
 
     @staticmethod
     def find_frequency_component() -> Component:

src/frequenz/sdk/timeseries/ev_charger_pool/_set_current_bounds.py

@@ -115,7 +115,7 @@ async def _run(self) -> None:
                     continue
                 latest_bound[bound.component_id] = bound
                 min_voltage = min(meter.voltage_per_phase)
-                logging.info("sending new bounds: %s", bound)
+                _logger.info("sending new bounds: %s", bound)
                 await api_client.set_bounds(
                     bound.component_id,
                     0,
@@ -124,7 +124,7 @@ async def _run(self) -> None:
             elif selected_from(selected, timer):
                 for bound in latest_bound.values():
                     min_voltage = min(meter.voltage_per_phase)
-                    logging.debug("resending bounds: %s", bound)
+                    _logger.debug("resending bounds: %s", bound)
                     await api_client.set_bounds(
                         bound.component_id,
                         0,

src/frequenz/sdk/timeseries/grid.py

@@ -15,6 +15,8 @@
 from ..microgrid.component._component import ComponentCategory
 from ..microgrid.fuse import Fuse
 
+_logger = logging.getLogger(__name__)
+
 
 @dataclass(frozen=True)
 class Grid:
@@ -49,7 +51,7 @@ def initialize(components: Iterable[Component]) -> None:
     grid_connections_count = len(grid_connections)
 
     if grid_connections_count == 0:
-        logging.info(
+        _logger.info(
             "No grid connection found for this microgrid. This is normal for an islanded microgrid."
         )
     elif grid_connections_count > 1: