added additional warnings about queue full.

snstac · Feb 4, 2025 · ea4e275 · ea4e275
1 parent 016e881
commit ea4e275
Showing 1 changed file with 6 additions and 2 deletions.
diff --git 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)