|
19 | 19 |
|
20 | 20 | try: |
21 | 21 | import litellm # type: ignore[import-not-found] |
22 | | - from litellm import input_callback, success_callback, failure_callback |
23 | 22 | except ImportError: |
24 | 23 | raise DidNotEnable("LiteLLM not installed") |
25 | 24 |
|
@@ -279,14 +278,14 @@ def __init__(self: "LiteLLMIntegration", include_prompts: bool = True) -> None: |
279 | 278 | @staticmethod |
280 | 279 | def setup_once() -> None: |
281 | 280 | """Set up LiteLLM callbacks for monitoring.""" |
282 | | - litellm_input_callback = input_callback or [] |
283 | | - if _input_callback not in litellm_input_callback: |
284 | | - litellm_input_callback.append(_input_callback) |
| 281 | + litellm.input_callback = litellm.input_callback or [] |
| 282 | + if _input_callback not in litellm.input_callback: |
| 283 | + litellm.input_callback.append(_input_callback) |
285 | 284 |
|
286 | | - litellm_success_callback = success_callback or [] |
287 | | - if _success_callback not in litellm_success_callback: |
288 | | - litellm_success_callback.append(_success_callback) |
| 285 | + litellm.success_callback = litellm.success_callback or [] |
| 286 | + if _success_callback not in litellm.success_callback: |
| 287 | + litellm.success_callback.append(_success_callback) |
289 | 288 |
|
290 | | - litellm_failure_callback = failure_callback or [] |
291 | | - if _failure_callback not in litellm_failure_callback: |
292 | | - litellm_failure_callback.append(_failure_callback) |
| 289 | + litellm.failure_callback = litellm.failure_callback or [] |
| 290 | + if _failure_callback not in litellm.failure_callback: |
| 291 | + litellm.failure_callback.append(_failure_callback) |
0 commit comments