cleanup redis cluster usage

This commit is contained in:
Ishaan Jaff 2025-02-10 12:31:05 -08:00
parent fc7899e715
commit 2d6a2cf948

View file

@ -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: