From 03e87469df5e796830c9935c4e413c03f1989bed Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Aleix=20Conchillo=20Flaqu=C3=A9?= Date: Mon, 28 Jul 2025 17:43:41 -0700 Subject: [PATCH] utils(asyncio): use trace logging for some cancelling messages --- src/pipecat/utils/asyncio/watchdog_priority_queue.py | 2 +- src/pipecat/utils/asyncio/watchdog_queue.py | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) 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.")