refactor: use fstrings for regular log output
This commit is contained in:
@@ -59,7 +59,7 @@ class RPCManager:
|
|||||||
logger.info("Cleaning up rpc modules ...")
|
logger.info("Cleaning up rpc modules ...")
|
||||||
while self.registered_modules:
|
while self.registered_modules:
|
||||||
mod = self.registered_modules.pop()
|
mod = self.registered_modules.pop()
|
||||||
logger.info("Cleaning up rpc.%s ...", mod.name)
|
logger.info(f"Cleaning up rpc.{mod.name} ...")
|
||||||
mod.cleanup()
|
mod.cleanup()
|
||||||
del mod
|
del mod
|
||||||
|
|
||||||
@@ -73,7 +73,7 @@ class RPCManager:
|
|||||||
}
|
}
|
||||||
"""
|
"""
|
||||||
if msg.get("type") not in NO_ECHO_MESSAGES:
|
if msg.get("type") not in NO_ECHO_MESSAGES:
|
||||||
logger.info("Sending rpc message: %s", msg)
|
logger.info(f"Sending rpc message: {msg}")
|
||||||
for mod in self.registered_modules:
|
for mod in self.registered_modules:
|
||||||
logger.debug("Forwarding message to rpc.%s", mod.name)
|
logger.debug("Forwarding message to rpc.%s", mod.name)
|
||||||
try:
|
try:
|
||||||
@@ -81,7 +81,7 @@ class RPCManager:
|
|||||||
except NotImplementedError:
|
except NotImplementedError:
|
||||||
logger.error(f"Message type '{msg['type']}' not implemented by handler {mod.name}.")
|
logger.error(f"Message type '{msg['type']}' not implemented by handler {mod.name}.")
|
||||||
except Exception:
|
except Exception:
|
||||||
logger.exception("Exception occurred within RPC module %s", mod.name)
|
logger.exception(f"Exception occurred within RPC module {mod.name}")
|
||||||
|
|
||||||
def process_msg_queue(self, queue: deque) -> None:
|
def process_msg_queue(self, queue: deque) -> None:
|
||||||
"""
|
"""
|
||||||
@@ -89,7 +89,7 @@ class RPCManager:
|
|||||||
"""
|
"""
|
||||||
while queue:
|
while queue:
|
||||||
msg = queue.popleft()
|
msg = queue.popleft()
|
||||||
logger.info("Sending rpc strategy_msg: %s", msg)
|
logger.info(f"Sending rpc strategy_msg: {msg}")
|
||||||
for mod in self.registered_modules:
|
for mod in self.registered_modules:
|
||||||
if mod._config.get(mod.name, {}).get("allow_custom_messages", False):
|
if mod._config.get(mod.name, {}).get("allow_custom_messages", False):
|
||||||
mod.send_msg(
|
mod.send_msg(
|
||||||
|
|||||||
Reference in New Issue
Block a user