dev

Author: marcin-usielski

moler/command_scheduler.py

@@ -43,7 +43,8 @@ def enqueue_starting_on_connection(connection_observer):
         )
         t1.daemon = True
         t1.start()
-        connection_observer.logger.warning(f"Requested to execute command ({connection_observer}) but the other command is running. Waiting for a free slot.")
+        connection_observer._log(logging.WARNING, f"Requested to execute command ({connection_observer}) but the other "
+                                 "command is running. Waiting for a free slot.")
 
     @staticmethod
     def dequeue_running_on_connection(connection_observer):

moler/connection_observer.py

@@ -3,7 +3,7 @@
 """Base class for all events and commands that are to be observed on connection."""
 
 __author__ = "Grzegorz Latuszek, Marcin Usielski, Michal Ernst"
-__copyright__ = "Copyright (C) 2018-2024 Nokia"
+__copyright__ = "Copyright (C) 2018-2025 Nokia"
 __email__ = (
     "[email protected], [email protected], [email protected]"
 )
@@ -546,7 +546,7 @@ def get_short_desc(self) -> str:
         """
         return f"Observer '{self.__class__.__module__}.{self}'"
 
-    def _log(self, lvl: int, msg: str, extra: dict = None, levels_to_go_up: int = 1) -> None:
+    def _log(self, lvl: int, msg: str, extra: Optional[dict] = None, levels_to_go_up: int = 1) -> None:
         """
         Log a message with the specified level.