From ea4e27515ed91d68ed1cdfb33e5ab76caedfd1f2 Mon Sep 17 00:00:00 2001 From: Greg Albrecht Date: Mon, 3 Feb 2025 16:30:03 -0800 Subject: [PATCH] added additional warnings about queue full. --- src/pytak/classes.py | 8 ++++++-- 1 file changed, 6 insertions(+), 2 deletions(-) diff --git a/src/pytak/classes.py b/src/pytak/classes.py index 9ab7a5b..5f16eae 100644 --- a/src/pytak/classes.py +++ b/src/pytak/classes.py @@ -269,12 +269,16 @@ async def put_queue( self._logger.debug("Queue size=%s", _queue.qsize()) if isinstance(_queue, asyncio.Queue): if _queue.full(): - self._logger.warning("Queue full, dropping oldest data.") + self._logger.warning( + "Queue full, dropping oldest data. Consider raising MAX_IN_QUEUE or MAX_OUT_QUEUE see https://pytak.rtfd.io/" + ) await _queue.get() await _queue.put(data) else: if _queue.full(): - self._logger.warning("Queue full, dropping oldest data.") + self._logger.warning( + "Queue full, dropping oldest data. Consider raising MAX_IN_QUEUE or MAX_OUT_QUEUE see https://pytak.rtfd.io/" + ) _queue.get_nowait() _queue.put_nowait(data)