phoenix/litellm-mirror
0
0
Fork 1
mirror of https://github.com/BerriAI/litellm.git synced 2025-04-26 11:14:04 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

refactor prometheus to be a customLogger class

Browse source
This commit is contained in:
Ishaan Jaff 2024-08-10 09:28:46 -07:00
parent 20ef72194c
commit ce9af1e1df
2 changed files with 13 additions and 3 deletions
Download patch file Download diff file Expand all files Collapse all files

1
litellm/__init__.py
View file

@ -43,6 +43,7 @@ _custom_logger_compatible_callbacks_literal = Literal[
"logfire", "logfire",
"dynamic_rate_limiter", "dynamic_rate_limiter",
"langsmith", "langsmith",
"prometheus",
"galileo", "galileo",
"braintrust", "braintrust",
"arize", "arize",

15
litellm/litellm_core_utils/litellm_logging.py
View file

@ -1904,9 +1904,6 @@ def set_callbacks(callback_list, function_id=None):
openMeterLogger = OpenMeterLogger() openMeterLogger = OpenMeterLogger()
elif callback == "datadog": elif callback == "datadog":
dataDogLogger = DataDogLogger() dataDogLogger = DataDogLogger()
elif callback == "prometheus":
if prometheusLogger is None:
prometheusLogger = PrometheusLogger()
elif callback == "dynamodb": elif callback == "dynamodb":
dynamoLogger = DyanmoDBLogger() dynamoLogger = DyanmoDBLogger()
elif callback == "s3": elif callback == "s3":
@ -1980,6 +1977,14 @@ def _init_custom_logger_compatible_class(
_langsmith_logger = LangsmithLogger() _langsmith_logger = LangsmithLogger()
_in_memory_loggers.append(_langsmith_logger) _in_memory_loggers.append(_langsmith_logger)
return _langsmith_logger # type: ignore return _langsmith_logger # type: ignore
elif logging_integration == "prometheus":
for callback in _in_memory_loggers:
if isinstance(callback, PrometheusLogger):
return callback # type: ignore
_prometheus_logger = PrometheusLogger()
_in_memory_loggers.append(_prometheus_logger)
return _prometheus_logger # type: ignore
elif logging_integration == "gcs_bucket": elif logging_integration == "gcs_bucket":
for callback in _in_memory_loggers: for callback in _in_memory_loggers:
if isinstance(callback, GCSBucketLogger): if isinstance(callback, GCSBucketLogger):
@ -2102,6 +2107,10 @@ def get_custom_logger_compatible_class(
for callback in _in_memory_loggers: for callback in _in_memory_loggers:
if isinstance(callback, LangsmithLogger): if isinstance(callback, LangsmithLogger):
return callback return callback
elif logging_integration == "prometheus":
for callback in _in_memory_loggers:
if isinstance(callback, PrometheusLogger):
return callback
elif logging_integration == "gcs_bucket": elif logging_integration == "gcs_bucket":
for callback in _in_memory_loggers: for callback in _in_memory_loggers:
if isinstance(callback, GCSBucketLogger): if isinstance(callback, GCSBucketLogger):