From 2eb18f18b27318ce1744e04507b42b2b56078c4a Mon Sep 17 00:00:00 2001 From: Steven Silvester Date: Wed, 2 Jul 2025 11:22:12 -0500 Subject: [PATCH] PYTHON-5428 Mark test_connection_close_does_not_block_other_operations as flaky (#2415) --- test/asynchronous/test_discovery_and_monitoring.py | 2 ++ test/test_discovery_and_monitoring.py | 2 ++ 2 files changed, 4 insertions(+) diff --git a/test/asynchronous/test_discovery_and_monitoring.py b/test/asynchronous/test_discovery_and_monitoring.py index 70348c8da..46799201f 100644 --- a/test/asynchronous/test_discovery_and_monitoring.py +++ b/test/asynchronous/test_discovery_and_monitoring.py @@ -24,6 +24,7 @@ import time 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 @@ class TestPoolManagement(AsyncIntegrationTest): @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 a0dabaaf8..83a4adf17 100644 --- a/test/test_discovery_and_monitoring.py +++ b/test/test_discovery_and_monitoring.py @@ -24,6 +24,7 @@ import time 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 @@ class TestPoolManagement(IntegrationTest): @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(