Fix various commands to work with Redis Cluster

Author: abrookins

tests/integration/test_aggregation.py

@@ -2,7 +2,7 @@
 
 from redisvl.index import SearchIndex
 from redisvl.query import HybridQuery
-from redisvl.query.filter import FilterExpression, Geo, GeoRadius, Num, Tag, Text
+from redisvl.query.filter import Geo, GeoRadius, Num, Tag, Text
 from redisvl.redis.utils import array_to_buffer
 from tests.conftest import skip_if_redis_version_below
 
@@ -275,7 +275,7 @@ def test_aggregate_query_with_text_filter(index):
         assert "medical" in result[text_field].lower()
 
     filter_expression = (Text(text_field) == ("medical")) & (
-        (Text(text_field) != ("research"))
+        Text(text_field) != ("research")
     )
     hybrid_query = HybridQuery(
         text=text,

tests/integration/test_message_history.py

@@ -3,7 +3,6 @@
 import pytest
 from redis.exceptions import ConnectionError
 
-from redisvl.exceptions import RedisModuleVersionError
 from redisvl.extensions.constants import ID_FIELD_NAME
 from redisvl.extensions.message_history import MessageHistory, SemanticMessageHistory
 from tests.conftest import skip_if_module_version_error

tests/integration/test_query.py

@@ -1,4 +1,3 @@
-import os
 import uuid
 from datetime import timedelta
 
@@ -622,9 +621,9 @@ def test_query_with_chunk_number_zero():
     expected_query_str = (
         "((@doc_base_id:{8675309} @file_id:{e9ffbac9ff6f67cc}) @chunk_number:[0 0])"
     )
-    assert (
-        str(filter_conditions) == expected_query_str
-    ), "Query with chunk_number zero is incorrect"
+    assert str(filter_conditions) == expected_query_str, (
+        "Query with chunk_number zero is incorrect"
+    )
 
 
 def test_hybrid_policy_batches_mode(index, vector_query):
@@ -755,37 +754,32 @@ def test_range_query_with_filter_and_hybrid_policy(index):
 
 
 def test_query_normalize_cosine_distance(index, normalized_vector_query):
-
     res = index.query(normalized_vector_query)
 
     for r in res:
         assert 0 <= float(r["vector_distance"]) <= 1
 
 
 def test_query_cosine_distance_un_normalized(index, vector_query):
-
     res = index.query(vector_query)
 
     assert any(float(r["vector_distance"]) > 1 for r in res)
 
 
 def test_query_l2_distance_un_normalized(L2_index, vector_query):
-
     res = L2_index.query(vector_query)
 
     assert any(float(r["vector_distance"]) > 1 for r in res)
 
 
 def test_query_l2_distance_normalized(L2_index, normalized_vector_query):
-
     res = L2_index.query(normalized_vector_query)
 
     for r in res:
         assert 0 <= float(r["vector_distance"]) <= 1
 
 
 def test_range_query_normalize_cosine_distance(index, normalized_range_query):
-
     res = index.query(normalized_range_query)
 
     for r in res: