debug

Author: blink1073

test/asynchronous/test_srv_polling.py

@@ -18,6 +18,7 @@
 import asyncio
 import sys
 import time
+from test.asynchronous.utils import flaky
 from test.utils_shared import FunctionCallRecorder
 from typing import Any
 
@@ -254,6 +255,7 @@ def final_callback():
             # Nodelist should reflect new valid DNS resolver response.
             await self.assert_nodelist_change(response_final, client)
 
+    @flaky  # PYTHON-5315
     async def test_recover_from_initially_empty_seedlist(self):
         def empty_seedlist():
             return []

test/asynchronous/unified_format.py

@@ -1380,8 +1380,8 @@ async def run_scenario(self, spec, uri=None):
         for flaky_test in flaky_tests:
             if re.match(flaky_test, self.id()) is not None:
                 decorator = flaky(reset_func=self.asyncSetUp, func_name=self.id())
-                func = decorator(func)
-                break
+                await decorator(func)
+                return
         await func()
 
     async def _run_scenario(self, spec, uri=None):

test/test_srv_polling.py

@@ -18,6 +18,7 @@
 import asyncio
 import sys
 import time
+from test.utils import flaky
 from test.utils_shared import FunctionCallRecorder
 from typing import Any
 
@@ -254,6 +255,7 @@ def final_callback():
             # Nodelist should reflect new valid DNS resolver response.
             self.assert_nodelist_change(response_final, client)
 
+    @flaky  # PYTHON-5315
     def test_recover_from_initially_empty_seedlist(self):
         def empty_seedlist():
             return []

test/unified_format.py

@@ -1367,8 +1367,8 @@ def run_scenario(self, spec, uri=None):
         for flaky_test in flaky_tests:
             if re.match(flaky_test, self.id()) is not None:
                 decorator = flaky(reset_func=self.setUp, func_name=self.id())
-                func = decorator(func)
-                break
+                decorator(func)
+                return
         func()
 
     def _run_scenario(self, spec, uri=None):