cleanup

Author: blink1073

test/asynchronous/test_csot.py

@@ -44,7 +44,7 @@
 class TestCSOT(AsyncIntegrationTest):
     RUN_ON_LOAD_BALANCER = True
 
-    @flaky
+    @flaky  # PYTHON-3522
     async def test_timeout_nested(self):
         coll = self.db.coll
         self.assertEqual(_csot.get_timeout(), None)
@@ -82,7 +82,7 @@ async def test_timeout_nested(self):
         self.assertEqual(_csot.get_rtt(), 0.0)
 
     @async_client_context.require_change_streams
-    @flaky
+    @flaky  # PYTHON-3522
     async def test_change_stream_can_resume_after_timeouts(self):
         coll = self.db.test
         await coll.insert_one({})

test/asynchronous/test_cursor.py

@@ -1416,7 +1416,7 @@ async def test_to_list_length(self):
         docs = await c.to_list(3)
         self.assertEqual(len(docs), 2)
 
-    @flaky
+    @flaky  # PYTHON-3522
     async def test_to_list_csot_applied(self):
         client = await self.async_single_client(timeoutMS=500, w=1)
         coll = client.pymongo.test
@@ -1458,7 +1458,7 @@ async def test_command_cursor_to_list_length(self):
         self.assertEqual(len(await result.to_list(1)), 1)
 
     @async_client_context.require_failCommand_blockConnection
-    @flaky
+    @flaky  # PYTHON-3522
     async def test_command_cursor_to_list_csot_applied(self):
         client = await self.async_single_client(timeoutMS=500, w=1)
         coll = client.pymongo.test

test/test_csot.py

@@ -44,7 +44,7 @@
 class TestCSOT(IntegrationTest):
     RUN_ON_LOAD_BALANCER = True
 
-    @flaky
+    @flaky  # PYTHON-3522
     def test_timeout_nested(self):
         coll = self.db.coll
         self.assertEqual(_csot.get_timeout(), None)
@@ -82,7 +82,7 @@ def test_timeout_nested(self):
         self.assertEqual(_csot.get_rtt(), 0.0)
 
     @client_context.require_change_streams
-    @flaky
+    @flaky  # PYTHON-3522
     def test_change_stream_can_resume_after_timeouts(self):
         coll = self.db.test
         coll.insert_one({})

test/test_cursor.py

@@ -1407,7 +1407,7 @@ def test_to_list_length(self):
         docs = c.to_list(3)
         self.assertEqual(len(docs), 2)
 
-    @flaky
+    @flaky  # PYTHON-3522
     def test_to_list_csot_applied(self):
         client = self.single_client(timeoutMS=500, w=1)
         coll = client.pymongo.test
@@ -1449,7 +1449,7 @@ def test_command_cursor_to_list_length(self):
         self.assertEqual(len(result.to_list(1)), 1)
 
     @client_context.require_failCommand_blockConnection
-    @flaky
+    @flaky  # PYTHON-3522
     def test_command_cursor_to_list_csot_applied(self):
         client = self.single_client(timeoutMS=500, w=1)
         coll = client.pymongo.test

test/test_topology.py

@@ -750,8 +750,7 @@ def get_primary():
 class TestTopologyErrors(TopologyTest):
     # Errors when calling hello.
 
-    # PYTHON-5366
-    @flaky
+    @flaky  # PYTHON-5366
     def test_pool_reset(self):
         # hello succeeds at first, then always raises socket error.
         hello_count = [0]