summaryrefslogtreecommitdiff
path: root/venv/lib/python3.11/site-packages/litestar/logging/picologging.py
diff options
context:
space:
mode:
authorcyfraeviolae <cyfraeviolae>2024-04-03 03:17:55 -0400
committercyfraeviolae <cyfraeviolae>2024-04-03 03:17:55 -0400
commit12cf076118570eebbff08c6b3090e0d4798447a1 (patch)
tree3ba25e17e3c3a5e82316558ba3864b955919ff72 /venv/lib/python3.11/site-packages/litestar/logging/picologging.py
parentc45662ff3923b34614ddcc8feb9195541166dcc5 (diff)
no venv
Diffstat (limited to 'venv/lib/python3.11/site-packages/litestar/logging/picologging.py')
-rw-r--r--venv/lib/python3.11/site-packages/litestar/logging/picologging.py39
1 files changed, 0 insertions, 39 deletions
diff --git a/venv/lib/python3.11/site-packages/litestar/logging/picologging.py b/venv/lib/python3.11/site-packages/litestar/logging/picologging.py
deleted file mode 100644
index 2cd599f..0000000
--- a/venv/lib/python3.11/site-packages/litestar/logging/picologging.py
+++ /dev/null
@@ -1,39 +0,0 @@
-from __future__ import annotations
-
-import atexit
-from queue import Queue
-from typing import Any
-
-from litestar.exceptions import MissingDependencyException
-from litestar.logging._utils import resolve_handlers
-
-__all__ = ("QueueListenerHandler",)
-
-
-try:
- import picologging # noqa: F401
-except ImportError as e:
- raise MissingDependencyException("picologging") from e
-
-from picologging import StreamHandler
-from picologging.handlers import QueueHandler, QueueListener
-
-
-class QueueListenerHandler(QueueHandler):
- """Configure queue listener and handler to support non-blocking logging configuration."""
-
- def __init__(self, handlers: list[Any] | None = None) -> None:
- """Initialize ``QueueListenerHandler``.
-
- Args:
- handlers: Optional 'ConvertingList'
-
- Notes:
- - Requires ``picologging`` to be installed.
- """
- super().__init__(Queue(-1))
- handlers = resolve_handlers(handlers) if handlers else [StreamHandler()]
- self.listener = QueueListener(self.queue, *handlers)
- self.listener.start()
-
- atexit.register(self.listener.stop)