scriptoriumadmin/litellm
1
0
Fork 0
mirror of https://github.com/BerriAI/litellm.git synced 2026-10-10 03:28:53 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions 84

batch debugging

Browse source
This commit is contained in:
Gary Caldwell 2025-04-26 10:46:08 -07:00
parent 29141d2bae
commit 5e529e1462
2 changed files with 3 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

1
litellm/integrations/SlackAlerting/slack_alerting.py
View file

@ -1422,6 +1422,7 @@ Model Info:
print(f"slack url before log_queue {slack_webhook_url}")
print(f"slack payload {payload}")
print(f"slack batchsize {self.batch_size}")
if isinstance(slack_webhook_url, list):
for url in slack_webhook_url:
self.log_queue.append(

2
litellm/integrations/custom_batch_logger.py
View file

@ -42,6 +42,7 @@ class CustomBatchLogger(CustomLogger):
await self.flush_queue()
async def flush_queue(self):
print(f"flushing queue: {self.flush_lock}")
if self.flush_lock is None:
return
@ -50,6 +51,7 @@ class CustomBatchLogger(CustomLogger):
verbose_logger.debug(
"CustomLogger: Flushing batch of %s events", len(self.log_queue)
)
print("calling send_batch")
await self.async_send_batch()
self.log_queue.clear()
self.last_flush_time = time.time()