skip tests

Author: dvora-h

redis/_parsers/helpers.py

@@ -379,13 +379,21 @@ def parse_item(item):
         # an O(N) complexity) instead of the command.
         if isinstance(item[3], list):
             result["command"] = space.join(item[3])
-            result["client_address"] = item[4]
-            result["client_name"] = item[5]
+            try:
+                result["client_address"] = item[4]
+                result["client_name"] = item[5]
+            except IndexError:
+                # The client address and name are not always present (in enterprise)
+                pass
         else:
             result["complexity"] = item[3]
             result["command"] = space.join(item[4])
-            result["client_address"] = item[5]
-            result["client_name"] = item[6]
+            try:
+                result["client_address"] = item[5]
+                result["client_name"] = item[6]
+            except IndexError:
+                # The client address and name are not always present (in enterprise)
+                pass
         return result
 
     return [parse_item(item) for item in response]
@@ -650,7 +658,11 @@ def parse_client_info(value):
         "omem",
         "tot-mem",
     }:
-        client_info[int_key] = int(client_info[int_key])
+        try:
+            client_info[int_key] = int(client_info[int_key])
+        except KeyError:
+            # not all fields exist in enterprise
+            pass
     return client_info
 
 

tests/test_asyncio/test_bloom.py

@@ -7,6 +7,7 @@
 from tests.conftest import (
     assert_resp_response,
     is_resp2_connection,
+    skip_if_redis_enterprise,
     skip_ifmodversion_lt,
 )
 
@@ -235,6 +236,7 @@ async def test_cms(decoded_r: redis.Redis):
 
 @pytest.mark.redismod
 @pytest.mark.onlynoncluster
+@skip_if_redis_enterprise()
 async def test_cms_merge(decoded_r: redis.Redis):
     assert await decoded_r.cms().initbydim("A", 1000, 5)
     assert await decoded_r.cms().initbydim("B", 1000, 5)
@@ -366,6 +368,7 @@ async def test_tdigest_reset(decoded_r: redis.Redis):
 
 @pytest.mark.redismod
 @pytest.mark.onlynoncluster
+@skip_if_redis_enterprise()
 async def test_tdigest_merge(decoded_r: redis.Redis):
     assert await decoded_r.tdigest().create("to-tDigest", 10)
     assert await decoded_r.tdigest().create("from-tDigest", 10)