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

utils(asyncio): use trace logging for some cancelling messages

Browse Source
This commit is contained in:
Aleix Conchillo Flaqué
2025-07-28 17:43:41 -07:00
parent 4b2ba2d69f
commit 03e87469df
2 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
src/pipecat/utils/asyncio/watchdog_priority_queue.py
View File

@@ -63,7 +63,7 @@ class WatchdogPriorityQueue(asyncio.PriorityQueue):
get_result = await super().get() get_result = await super().get()
if isinstance(get_result, _WatchdogPriorityCancelSentinel): if isinstance(get_result, _WatchdogPriorityCancelSentinel):
logger.debug( logger.trace(
"Received WatchdogPriorityCancelSentinel, throwing CancelledError to force cancelling" "Received WatchdogPriorityCancelSentinel, throwing CancelledError to force cancelling"
) )
raise asyncio.CancelledError("Cancelling watchdog queue get() call.") raise asyncio.CancelledError("Cancelling watchdog queue get() call.")

2
src/pipecat/utils/asyncio/watchdog_queue.py
View File

@@ -62,7 +62,7 @@ class WatchdogQueue(asyncio.Queue):
get_result = await super().get() get_result = await super().get()
if isinstance(get_result, _WatchdogQueueCancelSentinel): if isinstance(get_result, _WatchdogQueueCancelSentinel):
logger.debug( logger.trace(
"Received WatchdogQueueCancelFrame, throwing CancelledError to force cancelling" "Received WatchdogQueueCancelFrame, throwing CancelledError to force cancelling"
) )
raise asyncio.CancelledError("Cancelling watchdog queue get() call.") raise asyncio.CancelledError("Cancelling watchdog queue get() call.")