diff --git a/src/pipecat/utils/asyncio/watchdog_priority_queue.py b/src/pipecat/utils/asyncio/watchdog_priority_queue.py index 98d7f9172..900242d1d 100644 --- a/src/pipecat/utils/asyncio/watchdog_priority_queue.py +++ b/src/pipecat/utils/asyncio/watchdog_priority_queue.py @@ -63,7 +63,7 @@ class WatchdogPriorityQueue(asyncio.PriorityQueue): get_result = await super().get() if isinstance(get_result, _WatchdogPriorityCancelSentinel): - logger.debug( + logger.trace( "Received WatchdogPriorityCancelSentinel, throwing CancelledError to force cancelling" ) raise asyncio.CancelledError("Cancelling watchdog queue get() call.") diff --git a/src/pipecat/utils/asyncio/watchdog_queue.py b/src/pipecat/utils/asyncio/watchdog_queue.py index 53b04c534..b18632d10 100644 --- a/src/pipecat/utils/asyncio/watchdog_queue.py +++ b/src/pipecat/utils/asyncio/watchdog_queue.py @@ -62,7 +62,7 @@ class WatchdogQueue(asyncio.Queue): get_result = await super().get() if isinstance(get_result, _WatchdogQueueCancelSentinel): - logger.debug( + logger.trace( "Received WatchdogQueueCancelFrame, throwing CancelledError to force cancelling" ) raise asyncio.CancelledError("Cancelling watchdog queue get() call.")