wx44wx/pipecat
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

BaseObject: improve logging messages

Browse Source
This commit is contained in:
Aleix Conchillo Flaqué
2026-01-08 16:46:38 -08:00
parent 5cbb21afb2
commit 5f9e95038e
1 changed files with 4 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
src/pipecat/utils/base_object.py
View File

@@ -96,7 +96,7 @@ class BaseObject(ABC):
""" """
if self._event_tasks: if self._event_tasks:
event_names, tasks = zip(*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) await asyncio.wait(tasks)
def event_handler(self, event_name: str): def event_handler(self, event_name: str):
@@ -126,7 +126,7 @@ class BaseObject(ABC):
if event_name in self._event_handlers: if event_name in self._event_handlers:
self._event_handlers[event_name].handlers.append(handler) self._event_handlers[event_name].handlers.append(handler)
else: 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): def _register_event_handler(self, event_name: str, sync: bool = False):
"""Register an event handler type. """Register an event handler type.
@@ -140,7 +140,7 @@ class BaseObject(ABC):
name=event_name, handlers=[], is_sync=sync name=event_name, handlers=[], is_sync=sync
) )
else: 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): async def _call_event_handler(self, event_name: str, *args, **kwargs):
"""Call all registered handlers for the specified event. """Call all registered handlers for the specified event.
@@ -191,7 +191,7 @@ class BaseObject(ABC):
tb = traceback.extract_tb(e.__traceback__) tb = traceback.extract_tb(e.__traceback__)
last = tb[-1] last = tb[-1]
logger.error( 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): def _event_task_finished(self, task: asyncio.Task):