From 9b7b987b35902f4e9a26a1d6c57688f4504de47a Mon Sep 17 00:00:00 2001 From: Harshit Jain Date: Fri, 27 Feb 2026 15:15:57 +0530 Subject: [PATCH] fix: req changes --- litellm/integrations/datadog/datadog_metrics.py | 12 +++++------- 1 file changed, 5 insertions(+), 7 deletions(-) diff --git a/litellm/integrations/datadog/datadog_metrics.py b/litellm/integrations/datadog/datadog_metrics.py index a22efd66000..70576d2d157 100644 --- a/litellm/integrations/datadog/datadog_metrics.py +++ b/litellm/integrations/datadog/datadog_metrics.py @@ -209,16 +209,14 @@ class DatadogMetricsLogger(CustomBatchLogger): if not self.log_queue: return + batch = self.log_queue.copy() + payload_data: DatadogMetricsPayload = {"series": batch} + try: - # We must only send the current batch, so copy and clear log queue - batch = self.log_queue.copy() - # Note: CustomBatchLogger clears queue in flush_queue, but we'll manually copy what we need - - payload_data: DatadogMetricsPayload = {"series": batch} - await self._upload_to_datadog(payload_data) - except Exception as e: + # Re-insert failed batch so next flush retries + self.log_queue.extend(batch) verbose_logger.exception( f"Datadog Metrics: Error in async_send_batch: {str(e)}" )