diff --git a/redisvl/index/index.py b/redisvl/index/index.py index 4d7a871b..6b6fefc7 100644 --- a/redisvl/index/index.py +++ b/redisvl/index/index.py @@ -833,6 +833,13 @@ def drop_keys(self, keys: str | list[str]) -> int: int: Count of records deleted from Redis. """ if isinstance(keys, list): + # Check for cluster compatibility + if isinstance( + self._redis_client, RedisCluster + ) and not _keys_share_hash_tag(keys): + raise ValueError( + "All keys must share a hash tag when using Redis Cluster." + ) return self._redis_client.delete(*keys) # type: ignore else: return self._redis_client.delete(keys) # type: ignore