From 10d427aa2de1420b3c17ff460ff6057ccadfe404 Mon Sep 17 00:00:00 2001 From: miro Date: Thu, 21 Nov 2024 19:38:02 +0000 Subject: [PATCH] fix: update deprecated imports from ovos-utils --- ovos_messagebus/event_handler.py | 15 +++++++-------- 1 file changed, 7 insertions(+), 8 deletions(-) diff --git a/ovos_messagebus/event_handler.py b/ovos_messagebus/event_handler.py index 3ae8031..f6e488e 100644 --- a/ovos_messagebus/event_handler.py +++ b/ovos_messagebus/event_handler.py @@ -17,12 +17,12 @@ import sys import traceback -from ovos_utils.fakebus import Message -from ovos_utils.log import LOG +from ovos_bus_client.message import Message +from ovos_bus_client.session import SessionManager from ovos_config import Configuration +from ovos_utils.log import LOG from pyee import EventEmitter from tornado.websocket import WebSocketHandler -from ovos_bus_client.session import SessionManager client_connections = [] @@ -63,13 +63,12 @@ def on_message(self, message): if deserialized_message.msg_type not in self.filter_logs: LOG.debug(deserialized_message.msg_type + - f' source: {deserialized_message.context.get("source", [])}' + - f' destination: {deserialized_message.context.get("destination", [])}\n' - f'SESSION: {SessionManager.get(deserialized_message).serialize()}') + f' source: {deserialized_message.context.get("source", [])}' + + f' destination: {deserialized_message.context.get("destination", [])}\n' + f'SESSION: {SessionManager.get(deserialized_message).serialize()}') try: - self.emitter.emit(deserialized_message.msg_type, - deserialized_message) + self.emitter.emit(deserialized_message.msg_type, deserialized_message) except Exception as e: LOG.exception(e) traceback.print_exc(file=sys.stdout)