diff --git a/test/asynchronous/test_discovery_and_monitoring.py b/test/asynchronous/test_discovery_and_monitoring.py
index 70348c8daf..46799201f1 100644
--- a/test/asynchronous/test_discovery_and_monitoring.py
+++ b/test/asynchronous/test_discovery_and_monitoring.py
@@ -24,6 +24,7 @@
 from asyncio import StreamReader, StreamWriter
 from pathlib import Path
 from test.asynchronous.helpers import ConcurrentRunner
+from test.asynchronous.utils import flaky
 
 from pymongo.asynchronous.pool import AsyncConnection
 from pymongo.operations import _Op
@@ -378,6 +379,7 @@ async def test_pool_unpause(self):
     @async_client_context.require_failCommand_appName
     @async_client_context.require_test_commands
     @async_client_context.require_async
+    @flaky(reason="PYTHON-5428")
     async def test_connection_close_does_not_block_other_operations(self):
         listener = CMAPHeartbeatListener()
         client = await self.async_single_client(
diff --git a/test/test_discovery_and_monitoring.py b/test/test_discovery_and_monitoring.py
index a0dabaaf8e..83a4adf179 100644
--- a/test/test_discovery_and_monitoring.py
+++ b/test/test_discovery_and_monitoring.py
@@ -24,6 +24,7 @@
 from asyncio import StreamReader, StreamWriter
 from pathlib import Path
 from test.helpers import ConcurrentRunner
+from test.utils import flaky
 
 from pymongo.operations import _Op
 from pymongo.server_selectors import writable_server_selector
@@ -378,6 +379,7 @@ def test_pool_unpause(self):
     @client_context.require_failCommand_appName
     @client_context.require_test_commands
     @client_context.require_async
+    @flaky(reason="PYTHON-5428")
     def test_connection_close_does_not_block_other_operations(self):
         listener = CMAPHeartbeatListener()
         client = self.single_client(