From 5f9e95038e6a14cf1c459a06822d3eee2ec16b73 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Aleix=20Conchillo=20Flaqu=C3=A9?= Date: Thu, 8 Jan 2026 16:46:38 -0800 Subject: [PATCH] BaseObject: improve logging messages --- src/pipecat/utils/base_object.py | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/src/pipecat/utils/base_object.py b/src/pipecat/utils/base_object.py index 6a8ff0681..f6e4c47de 100644 --- a/src/pipecat/utils/base_object.py +++ b/src/pipecat/utils/base_object.py @@ -96,7 +96,7 @@ class BaseObject(ABC): """ if self._event_tasks: event_names, tasks = zip(*self._event_tasks) - logger.debug(f"{self} waiting on event handlers to finish {list(event_names)}...") + logger.debug(f"{self}: waiting on event handlers to finish {list(event_names)}...") await asyncio.wait(tasks) def event_handler(self, event_name: str): @@ -126,7 +126,7 @@ class BaseObject(ABC): if event_name in self._event_handlers: self._event_handlers[event_name].handlers.append(handler) else: - logger.warning(f"Event handler {event_name} not registered") + logger.warning(f"{self}: event handler {event_name} not registered") def _register_event_handler(self, event_name: str, sync: bool = False): """Register an event handler type. @@ -140,7 +140,7 @@ class BaseObject(ABC): name=event_name, handlers=[], is_sync=sync ) else: - logger.warning(f"Event handler {event_name} already registered") + logger.warning(f"{self}: event handler {event_name} already registered") async def _call_event_handler(self, event_name: str, *args, **kwargs): """Call all registered handlers for the specified event. @@ -191,7 +191,7 @@ class BaseObject(ABC): tb = traceback.extract_tb(e.__traceback__) last = tb[-1] logger.error( - f"Uncaught exception in event handler '{event_name}' ({last.filename}:{last.lineno}): {e}" + f"{self}: uncaught exception in event handler '{event_name}' ({last.filename}:{last.lineno}): {e}" ) def _event_task_finished(self, task: asyncio.Task):