From 7b2ebb762a15f15d520d3eb79e4fbbf3bbee069f Mon Sep 17 00:00:00 2001 From: Noah Stapp Date: Thu, 27 Aug 2026 11:17:06 -0400 Subject: [PATCH] PYTHON-6056 - Search index helper prose tests are flaky --- test/asynchronous/test_index_management.py | 9 +++++++++ test/test_index_management.py | 9 +++++++++ 2 files changed, 18 insertions(+) diff --git a/test/asynchronous/test_index_management.py b/test/asynchronous/test_index_management.py index 09b4f364c0..a94906bb5e 100644 --- a/test/asynchronous/test_index_management.py +++ b/test/asynchronous/test_index_management.py @@ -27,6 +27,8 @@ import pytest +from test.asynchronous.utils import flaky + sys.path[0:0] = [""] from pymongo.errors import OperationFailure @@ -138,6 +140,7 @@ async def test_comment_field(self): class TestSearchIndexProse(SearchIndexIntegrationBase): db_name = "test_search_index_prose" + @flaky(reason="PYTHON-6056", affects_cpython_linux=True) async def test_case_1(self): """Driver can successfully create and list search indexes.""" @@ -156,6 +159,7 @@ async def test_case_1(self): self.assertIn("latestDefinition", index) self.assertEqual(index["latestDefinition"], model["definition"]) + @flaky(reason="PYTHON-6056", affects_cpython_linux=True) async def test_case_2(self): """Driver can successfully create multiple indexes in batch.""" @@ -188,6 +192,7 @@ async def test_case_2(self): self.assertIn("latestDefinition", index) self.assertEqual(index["latestDefinition"], definition) + @flaky(reason="PYTHON-6056", affects_cpython_linux=True) async def test_case_3(self): """Driver can successfully drop search indexes.""" @@ -215,6 +220,7 @@ async def test_case_3(self): raise TimeoutError("Timed out waiting for index deletion") await asyncio.sleep(5) + @flaky(reason="PYTHON-6056", affects_cpython_linux=True) async def test_case_4(self): """Driver can update a search index.""" @@ -245,6 +251,7 @@ async def test_case_4(self): self.assertIn("latestDefinition", index) self.assertEqual(index["latestDefinition"], model2["definition"]) + @flaky(reason="PYTHON-6056", affects_cpython_linux=True) async def test_case_5(self): """``dropSearchIndex`` suppresses namespace not found errors.""" # Create a driver-side collection object for a randomly generated collection name. Do not create this collection on the server. @@ -253,6 +260,7 @@ async def test_case_5(self): # Run a ``dropSearchIndex`` command and assert that no error is thrown. await coll0.drop_search_index("foo") + @flaky(reason="PYTHON-6056", affects_cpython_linux=True) async def test_case_6(self): """Driver can successfully create and list search indexes with non-default readConcern and writeConcern.""" @@ -277,6 +285,7 @@ async def test_case_6(self): self.assertIn("latestDefinition", index) self.assertEqual(index["latestDefinition"], model["definition"]) + @flaky(reason="PYTHON-6056", affects_cpython_linux=True) async def test_case_7(self): """Driver handles index types.""" diff --git a/test/test_index_management.py b/test/test_index_management.py index 6dbd7b9c01..6af2534cff 100644 --- a/test/test_index_management.py +++ b/test/test_index_management.py @@ -27,6 +27,8 @@ import pytest +from test.utils import flaky + sys.path[0:0] = [""] from pymongo.errors import OperationFailure @@ -136,6 +138,7 @@ def test_comment_field(self): class TestSearchIndexProse(SearchIndexIntegrationBase): db_name = "test_search_index_prose" + @flaky(reason="PYTHON-6056", affects_cpython_linux=True) def test_case_1(self): """Driver can successfully create and list search indexes.""" @@ -154,6 +157,7 @@ def test_case_1(self): self.assertIn("latestDefinition", index) self.assertEqual(index["latestDefinition"], model["definition"]) + @flaky(reason="PYTHON-6056", affects_cpython_linux=True) def test_case_2(self): """Driver can successfully create multiple indexes in batch.""" @@ -186,6 +190,7 @@ def test_case_2(self): self.assertIn("latestDefinition", index) self.assertEqual(index["latestDefinition"], definition) + @flaky(reason="PYTHON-6056", affects_cpython_linux=True) def test_case_3(self): """Driver can successfully drop search indexes.""" @@ -213,6 +218,7 @@ def test_case_3(self): raise TimeoutError("Timed out waiting for index deletion") time.sleep(5) + @flaky(reason="PYTHON-6056", affects_cpython_linux=True) def test_case_4(self): """Driver can update a search index.""" @@ -243,6 +249,7 @@ def test_case_4(self): self.assertIn("latestDefinition", index) self.assertEqual(index["latestDefinition"], model2["definition"]) + @flaky(reason="PYTHON-6056", affects_cpython_linux=True) def test_case_5(self): """``dropSearchIndex`` suppresses namespace not found errors.""" # Create a driver-side collection object for a randomly generated collection name. Do not create this collection on the server. @@ -251,6 +258,7 @@ def test_case_5(self): # Run a ``dropSearchIndex`` command and assert that no error is thrown. coll0.drop_search_index("foo") + @flaky(reason="PYTHON-6056", affects_cpython_linux=True) def test_case_6(self): """Driver can successfully create and list search indexes with non-default readConcern and writeConcern.""" @@ -275,6 +283,7 @@ def test_case_6(self): self.assertIn("latestDefinition", index) self.assertEqual(index["latestDefinition"], model["definition"]) + @flaky(reason="PYTHON-6056", affects_cpython_linux=True) def test_case_7(self): """Driver handles index types."""