diff --git a/litellm/router_strategy/budget_limiter.py b/litellm/router_strategy/budget_limiter.py index fdd4a45e0e1..154f778d6cf 100644 --- a/litellm/router_strategy/budget_limiter.py +++ b/litellm/router_strategy/budget_limiter.py @@ -353,13 +353,7 @@ class RouterBudgetLimiting(CustomLogger): self.redis_increment_operation_queue.append(increment_op) def _get_redis_increment_queue_lock(self) -> asyncio.Lock: - queue_lock: Optional[asyncio.Lock] = getattr( - self, "_redis_increment_queue_lock", None - ) - if queue_lock is None: - queue_lock = asyncio.Lock() - self._redis_increment_queue_lock = queue_lock - return queue_lock + return self._redis_increment_queue_lock async def async_log_success_event(self, kwargs, response_obj, start_time, end_time): """Original method now uses helper functions"""