PYCBC-1688: Transactions - GetMulti tests should skip unsupported server

versions

Changes
=======
* Update tests to skip if server version does not support required
  features

Results
=======
* Integration tests pass or skip based on server version

Change-Id: I6574396600c76895f69e7dd240adb0f15b8da4ad
Reviewed-on: https://review.couchbase.org/c/couchbase-python-client/+/228056
Tested-by: Build Bot <build@couchbase.com>
Reviewed-by: Dimitris Christodoulou <dimitris.christodoulou@couchbase.com>

Author: thejcfactor

acouchbase/tests/transactions_t.py

@@ -134,6 +134,12 @@ def check_binary_txns_not_supported(self, cb_env):
                                                            cb_env.mock_server_type,
                                                            cb_env.server_version_patch)
 
+    @pytest.fixture(scope="class")
+    def check_replica_read_supported(self, cb_env):
+        EnvironmentFeatures.check_if_feature_supported('subdoc_replica_read',
+                                                       cb_env.server_version_short,
+                                                       cb_env.mock_server_type)
+
     @pytest.fixture(scope='class')
     def check_server_groups_supported(self, cb_env):
         EnvironmentFeatures.check_if_feature_supported('server_groups',
@@ -355,6 +361,7 @@ async def txn_logic(ctx):
         assert num_attempts == 1
 
     @pytest.mark.asyncio
+    @pytest.mark.usefixtures('check_binary_txns_supported')
     async def test_get_multi_binary(self, cb_env):
         key1 = cb_env.get_new_doc(key_only=True)
         tc = RawBinaryTranscoder()
@@ -486,6 +493,9 @@ async def txn_logic(ctx):
                 pass
 
     @pytest.mark.asyncio
+    @pytest.mark.usefixtures('check_binary_txns_supported')
+    @pytest.mark.usefixtures('check_replica_read_supported')
+    @pytest.mark.usefixtures('check_server_groups_supported')
     async def test_get_multi_replicas_from_preferred_server_group_binary(self, cb_env):
         key1 = cb_env.get_new_doc(key_only=True)
         tc = RawBinaryTranscoder()
@@ -514,6 +524,8 @@ async def txn_logic(ctx):
                 pass
 
     @pytest.mark.asyncio
+    @pytest.mark.usefixtures('check_replica_read_supported')
+    @pytest.mark.usefixtures('check_server_groups_supported')
     async def test_get_multi_replicas_from_preferred_server_group_not_exists(self, cb_env):
         key1, value1 = cb_env.get_new_doc()
         key2 = cb_env.get_new_doc(key_only=True)
@@ -539,6 +551,8 @@ async def txn_logic(ctx):
             pass
 
     @pytest.mark.asyncio
+    @pytest.mark.usefixtures('check_replica_read_supported')
+    @pytest.mark.usefixtures('check_server_groups_supported')
     async def test_get_multi_replicas_from_preferred_server_group_invalid_index(self, cb_env):
         key1, value1 = cb_env.get_new_doc()
         key2 = cb_env.get_new_doc(key_only=True)
@@ -563,6 +577,8 @@ async def txn_logic(ctx):
             pass
 
     @pytest.mark.asyncio
+    @pytest.mark.usefixtures('check_replica_read_supported')
+    @pytest.mark.usefixtures('check_server_groups_supported')
     async def test_get_multi_replicas_from_preferred_server_group_options(self, cb_env):
         key1, value1 = cb_env.get_new_doc()
         key2, value2 = cb_env.get_new_doc()
@@ -589,6 +605,8 @@ async def txn_logic(ctx):
                 pass
 
     @pytest.mark.asyncio
+    @pytest.mark.usefixtures('check_replica_read_supported')
+    @pytest.mark.usefixtures('check_server_groups_supported')
     async def test_get_multi_replicas_from_preferred_server_group_simple(self, cb_env):
         keys_and_docs = []
         for _ in range(3):

couchbase/tests/transactions_t.py

@@ -132,6 +132,12 @@ def check_binary_txns_not_supported(self, cb_env):
                                                            cb_env.mock_server_type,
                                                            cb_env.server_version_patch)
 
+    @pytest.fixture(scope="class")
+    def check_replica_read_supported(self, cb_env):
+        EnvironmentFeatures.check_if_feature_supported('subdoc_replica_read',
+                                                       cb_env.server_version_short,
+                                                       cb_env.mock_server_type)
+
     @pytest.fixture(scope='class')
     def check_server_groups_supported(self, cb_env):
         EnvironmentFeatures.check_if_feature_supported('server_groups',
@@ -343,6 +349,7 @@ def txn_logic(ctx):
 
         assert num_attempts == 1
 
+    @pytest.mark.usefixtures('check_binary_txns_supported')
     def test_get_multi_binary(self, cb_env):
         key1 = cb_env.get_new_doc(key_only=True)
         tc = RawBinaryTranscoder()
@@ -469,6 +476,9 @@ def txn_logic(ctx):
             except DocumentNotFoundException:
                 pass
 
+    @pytest.mark.usefixtures('check_binary_txns_supported')
+    @pytest.mark.usefixtures('check_replica_read_supported')
+    @pytest.mark.usefixtures('check_server_groups_supported')
     def test_get_multi_replicas_from_preferred_server_group_binary(self, cb_env):
         key1 = cb_env.get_new_doc(key_only=True)
         tc = RawBinaryTranscoder()
@@ -496,6 +506,8 @@ def txn_logic(ctx):
             except DocumentNotFoundException:
                 pass
 
+    @pytest.mark.usefixtures('check_replica_read_supported')
+    @pytest.mark.usefixtures('check_server_groups_supported')
     def test_get_multi_replicas_from_preferred_server_group_not_exists(self, cb_env):
         key1, value1 = cb_env.get_new_doc()
         key2 = cb_env.get_new_doc(key_only=True)
@@ -520,6 +532,8 @@ def txn_logic(ctx):
         except DocumentNotFoundException:
             pass
 
+    @pytest.mark.usefixtures('check_replica_read_supported')
+    @pytest.mark.usefixtures('check_server_groups_supported')
     def test_get_multi_replicas_from_preferred_server_group_invalid_index(self, cb_env):
         key1, value1 = cb_env.get_new_doc()
         key2 = cb_env.get_new_doc(key_only=True)
@@ -543,6 +557,8 @@ def txn_logic(ctx):
         except DocumentNotFoundException:
             pass
 
+    @pytest.mark.usefixtures('check_replica_read_supported')
+    @pytest.mark.usefixtures('check_server_groups_supported')
     def test_get_multi_replicas_from_preferred_server_group_options(self, cb_env):
         key1, value1 = cb_env.get_new_doc()
         key2, value2 = cb_env.get_new_doc()
@@ -568,6 +584,8 @@ def txn_logic(ctx):
             except DocumentNotFoundException:
                 pass
 
+    @pytest.mark.usefixtures('check_replica_read_supported')
+    @pytest.mark.usefixtures('check_server_groups_supported')
     def test_get_multi_replicas_from_preferred_server_group_simple(self, cb_env):
         keys_and_docs = []
         for _ in range(3):