diff --git a/test/asynchronous/test_pooling.py b/test/asynchronous/test_pooling.py index 66edf0177f..cbf6d336bd 100644 --- a/test/asynchronous/test_pooling.py +++ b/test/asynchronous/test_pooling.py @@ -21,7 +21,7 @@ import socket import sys import time -from test.asynchronous.utils import async_get_pool, async_joinall +from test.asynchronous.utils import async_get_pool, async_joinall, flaky from bson.codec_options import DEFAULT_CODEC_OPTIONS from bson.son import SON @@ -429,6 +429,7 @@ async def find_one(): # maxConnecting = unbounded: 30+ connections in ~0.140+ seconds print(len(pool.conns)) + @flaky(reason="PYTHON-5492") @async_client_context.require_failCommand_appName async def test_csot_timeout_message(self): client = await self.async_rs_or_single_client(appName="connectionTimeoutApp") diff --git a/test/test_pooling.py b/test/test_pooling.py index b995c467c2..5ce4284e33 100644 --- a/test/test_pooling.py +++ b/test/test_pooling.py @@ -21,7 +21,7 @@ import socket import sys import time -from test.utils import get_pool, joinall +from test.utils import flaky, get_pool, joinall from bson.codec_options import DEFAULT_CODEC_OPTIONS from bson.son import SON @@ -429,6 +429,7 @@ def find_one(): # maxConnecting = unbounded: 30+ connections in ~0.140+ seconds print(len(pool.conns)) + @flaky(reason="PYTHON-5492") @client_context.require_failCommand_appName def test_csot_timeout_message(self): client = self.rs_or_single_client(appName="connectionTimeoutApp")