diff --git a/test/asynchronous/test_bulk.py b/test/asynchronous/test_bulk.py index b5f2eefde..79d8e1a0f 100644 --- a/test/asynchronous/test_bulk.py +++ b/test/asynchronous/test_bulk.py @@ -976,6 +976,7 @@ class AsyncTestBulkWriteConcern(AsyncBulkTestBase): finally: await self.secondary.admin.command("configureFailPoint", "rsSyncApplyStop", mode="off") + @async_client_context.require_version_max(7, 1) # PYTHON-4560 @async_client_context.require_replica_set @async_client_context.require_secondaries_count(1) async def test_write_concern_failure_ordered(self): @@ -1055,6 +1056,7 @@ class AsyncTestBulkWriteConcern(AsyncBulkTestBase): failed = details["writeErrors"][0] self.assertTrue("duplicate" in failed["errmsg"]) + @async_client_context.require_version_max(7, 1) # PYTHON-4560 @async_client_context.require_replica_set @async_client_context.require_secondaries_count(1) async def test_write_concern_failure_unordered(self): diff --git a/test/test_bulk.py b/test/test_bulk.py index 9069109cf..63b8c7790 100644 --- a/test/test_bulk.py +++ b/test/test_bulk.py @@ -974,6 +974,7 @@ class TestBulkWriteConcern(BulkTestBase): finally: self.secondary.admin.command("configureFailPoint", "rsSyncApplyStop", mode="off") + @client_context.require_version_max(7, 1) # PYTHON-4560 @client_context.require_replica_set @client_context.require_secondaries_count(1) def test_write_concern_failure_ordered(self): @@ -1053,6 +1054,7 @@ class TestBulkWriteConcern(BulkTestBase): failed = details["writeErrors"][0] self.assertTrue("duplicate" in failed["errmsg"]) + @client_context.require_version_max(7, 1) # PYTHON-4560 @client_context.require_replica_set @client_context.require_secondaries_count(1) def test_write_concern_failure_unordered(self):