mirror of
https://github.com/BerriAI/litellm.git
synced 2026-09-16 23:41:43 +00:00
Merge pull request #41306 from BerriAI/litellm_lit2435_litellm_log_error_silences_info
fix(proxy): honor LITELLM_LOG for uvicorn and proxy extras loggers
This commit is contained in:
commit
3413efcd7f
5 changed files with 75 additions and 3 deletions
|
|
@ -40,4 +40,4 @@ if not logger.handlers:
|
|||
logging.Formatter("%(asctime)s - %(name)s - %(levelname)s - %(message)s")
|
||||
)
|
||||
logger.addHandler(handler)
|
||||
logger.setLevel(logging.INFO)
|
||||
logger.setLevel(os.getenv("LITELLM_LOG", "INFO").upper())
|
||||
|
|
|
|||
|
|
@ -401,10 +401,14 @@ def _parse_json_logs_env(value: str | None) -> bool:
|
|||
return (value or "").lower() == "true"
|
||||
|
||||
|
||||
def resolve_log_level(log_level: str) -> int:
|
||||
return getattr(logging, log_level.upper())
|
||||
|
||||
|
||||
json_logs: Final = _parse_json_logs_env(os.getenv("JSON_LOGS"))
|
||||
# Create a handler for the logger (you may need to adapt this based on your needs)
|
||||
log_level: Final = os.getenv("LITELLM_LOG", "DEBUG")
|
||||
numeric_level: Final[str] = getattr(logging, log_level.upper())
|
||||
numeric_level: Final[int] = resolve_log_level(log_level)
|
||||
handler: Final = LevelRoutingStreamHandler()
|
||||
handler.setLevel(numeric_level)
|
||||
handler.addFilter(_secret_filter)
|
||||
|
|
|
|||
|
|
@ -261,7 +261,7 @@ class ProxyInitializationHelpers:
|
|||
import uvicorn
|
||||
|
||||
import litellm
|
||||
from litellm._logging import _get_uvicorn_json_log_config
|
||||
from litellm._logging import _get_uvicorn_json_log_config, resolve_log_level
|
||||
|
||||
uvicorn_args: Final = {
|
||||
"app": "litellm.proxy.proxy_server:app",
|
||||
|
|
@ -275,6 +275,8 @@ class ProxyInitializationHelpers:
|
|||
elif litellm.json_logs:
|
||||
# Use JSON log config for uvicorn to ensure all logs (including exceptions) are JSON
|
||||
uvicorn_args["log_config"] = _get_uvicorn_json_log_config()
|
||||
elif litellm_log := os.environ.get("LITELLM_LOG"):
|
||||
uvicorn_args["log_level"] = resolve_log_level(litellm_log)
|
||||
if keepalive_timeout is not None:
|
||||
uvicorn_args["timeout_keep_alive"] = keepalive_timeout
|
||||
if timeout_worker_healthcheck is not None:
|
||||
|
|
|
|||
|
|
@ -0,0 +1,37 @@
|
|||
import importlib
|
||||
import logging
|
||||
from collections.abc import Iterator
|
||||
|
||||
import pytest
|
||||
|
||||
import litellm_proxy_extras._logging as extras_logging
|
||||
|
||||
|
||||
@pytest.fixture
|
||||
def fresh_extras_logger() -> Iterator[logging.Logger]:
|
||||
logger = logging.getLogger("litellm_proxy_extras")
|
||||
saved_handlers = logger.handlers[:]
|
||||
saved_level = logger.level
|
||||
logger.handlers[:] = []
|
||||
try:
|
||||
yield logger
|
||||
finally:
|
||||
logger.handlers[:] = saved_handlers
|
||||
logger.setLevel(saved_level)
|
||||
|
||||
|
||||
def test_litellm_log_error_silences_extras_info_lines(monkeypatch, fresh_extras_logger):
|
||||
monkeypatch.setenv("LITELLM_LOG", "ERROR")
|
||||
reloaded = importlib.reload(extras_logging).logger
|
||||
assert reloaded is fresh_extras_logger
|
||||
assert reloaded.isEnabledFor(logging.INFO) is False
|
||||
assert reloaded.isEnabledFor(logging.ERROR) is True
|
||||
|
||||
|
||||
@pytest.mark.parametrize("litellm_log", [None, "info", "DEBUG"])
|
||||
def test_unset_or_verbose_litellm_log_keeps_extras_info_lines(monkeypatch, fresh_extras_logger, litellm_log):
|
||||
if litellm_log is None:
|
||||
monkeypatch.delenv("LITELLM_LOG", raising=False)
|
||||
else:
|
||||
monkeypatch.setenv("LITELLM_LOG", litellm_log)
|
||||
assert importlib.reload(extras_logging).logger.isEnabledFor(logging.INFO) is True
|
||||
|
|
@ -139,6 +139,35 @@ class TestProxyInitializationHelpers:
|
|||
)
|
||||
assert args["timeout_worker_healthcheck"] == 15
|
||||
|
||||
@staticmethod
|
||||
def _uvicorn_access_info_enabled(args: dict) -> bool:
|
||||
import logging
|
||||
|
||||
loggers = tuple(logging.getLogger(n) for n in ("uvicorn", "uvicorn.error", "uvicorn.access", "uvicorn.asgi"))
|
||||
saved = tuple((lg, lg.handlers[:], lg.level, lg.propagate) for lg in loggers)
|
||||
try:
|
||||
uvicorn.Config(**args).configure_logging()
|
||||
return logging.getLogger("uvicorn.access").isEnabledFor(logging.INFO)
|
||||
finally:
|
||||
for lg, handlers, level, propagate in saved:
|
||||
lg.handlers[:] = handlers
|
||||
lg.setLevel(level)
|
||||
lg.propagate = propagate
|
||||
|
||||
def test_litellm_log_error_silences_uvicorn_info_lines(self, monkeypatch):
|
||||
monkeypatch.setenv("LITELLM_LOG", "ERROR")
|
||||
args = ProxyInitializationHelpers._get_default_unvicorn_init_args("localhost", 8000)
|
||||
|
||||
assert "log_config" not in args
|
||||
assert self._uvicorn_access_info_enabled(args) is False
|
||||
|
||||
def test_unset_litellm_log_keeps_uvicorn_default_info_lines(self, monkeypatch):
|
||||
monkeypatch.delenv("LITELLM_LOG", raising=False)
|
||||
args = ProxyInitializationHelpers._get_default_unvicorn_init_args("localhost", 8000)
|
||||
|
||||
assert "log_level" not in args
|
||||
assert self._uvicorn_access_info_enabled(args) is True
|
||||
|
||||
def test_installed_uvicorn_supports_worker_flags(self):
|
||||
params = inspect.signature(uvicorn.Config.__init__).parameters
|
||||
assert "timeout_worker_healthcheck" in params
|
||||
|
|
|
|||
Loading…
Add table
Reference in a new issue