From 2d6a2cf9489da204a09521b92e3da5607a1742cb Mon Sep 17 00:00:00 2001
From: Ishaan Jaff <ishaanjaffer0324@gmail.com>
Date: Mon, 10 Feb 2025 12:31:05 -0800
Subject: [PATCH] cleanup redis cluster usage

---
 litellm/caching/redis_cache.py | 4 +---
 1 file changed, 1 insertion(+), 3 deletions(-)

diff --git a/litellm/caching/redis_cache.py b/litellm/caching/redis_cache.py
index 2e26adaf22c..a46f9cb9f17 100644
--- a/litellm/caching/redis_cache.py
+++ b/litellm/caching/redis_cache.py
@@ -28,10 +28,8 @@ if TYPE_CHECKING:
     from opentelemetry.trace import Span as _Span
     from redis.asyncio import Redis
     from redis.asyncio.client import Pipeline
-    from redis.asyncio.cluster import ClusterPipeline
 
     pipeline = Pipeline
-    cluster_pipeline = ClusterPipeline
     async_redis_client = Redis
     Span = _Span
 else:
@@ -348,7 +346,7 @@ class RedisCache(BaseCache):
 
     async def _pipeline_helper(
         self,
-        pipe: Union[pipeline, cluster_pipeline],
+        pipe: pipeline,
         cache_list: List[Tuple[Any, Any]],
         ttl: Optional[float],
     ) -> List: