diff --git a/test/asynchronous/test_bulk.py b/test/asynchronous/test_bulk.py index b5f2eefdef..79d8e1a0f1 100644 --- a/test/asynchronous/test_bulk.py +++ b/test/asynchronous/test_bulk.py @@ -976,6 +976,7 @@ async def cause_wtimeout(self, requests, ordered): 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 @@ async def test_write_concern_failure_ordered(self): 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 9069109cfa..63b8c7790a 100644 --- a/test/test_bulk.py +++ b/test/test_bulk.py @@ -974,6 +974,7 @@ def cause_wtimeout(self, requests, ordered): 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 @@ def test_write_concern_failure_ordered(self): 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):