|
5 | 5 | """
|
6 | 6 |
|
7 | 7 | import json
|
8 |
| -from typing import TYPE_CHECKING, Any, Dict, List, Optional, Union |
| 8 | +from typing import TYPE_CHECKING, Any, Dict, List, Literal, Optional, Union |
9 | 9 |
|
10 | 10 | from litellm._logging import verbose_proxy_logger
|
11 | 11 | from litellm.caching import RedisCache
|
| 12 | +from litellm.constants import MAX_REDIS_BUFFER_DEQUEUE_COUNT, REDIS_UPDATE_BUFFER_KEY |
12 | 13 | from litellm.litellm_core_utils.safe_json_dumps import safe_dumps
|
13 | 14 | from litellm.proxy._types import DBSpendUpdateTransactions
|
14 | 15 | from litellm.secret_managers.main import str_to_bool
|
|
18 | 19 | else:
|
19 | 20 | PrismaClient = Any
|
20 | 21 |
|
21 |
| -REDIS_UPDATE_BUFFER_KEY = "litellm_spend_update_buffer" |
22 |
| -MAX_REDIS_BUFFER_DEQUEUE_COUNT = 100 |
23 |
| - |
24 | 22 |
|
25 | 23 | class RedisUpdateBuffer:
|
26 | 24 | """
|
@@ -245,9 +243,9 @@ def _combine_list_of_transactions(
|
245 | 243 | # Process each field type
|
246 | 244 | for field in transaction_fields:
|
247 | 245 | if transaction.get(field):
|
248 |
| - for entity_id, amount in transaction[field].items(): |
249 |
| - combined_transaction[field][entity_id] = ( |
250 |
| - combined_transaction[field].get(entity_id, 0) + amount |
| 246 | + for entity_id, amount in transaction[field].items(): # type: ignore |
| 247 | + combined_transaction[field][entity_id] = ( # type: ignore |
| 248 | + combined_transaction[field].get(entity_id, 0) + amount # type: ignore |
251 | 249 | )
|
252 | 250 |
|
253 | 251 | return combined_transaction
|
0 commit comments