More cleanup

Author: NoahStapp

test/asynchronous/test_bulk.py

@@ -301,6 +301,7 @@ async def test_numerous_inserts(self):
 
     async def test_bulk_max_message_size(self):
         await self.coll.delete_many({})
+        self.addAsyncCleanup(self.coll.delete_many, {})
         _16_MB = 16 * 1000 * 1000
         # Generate a list of documents such that the first batched OP_MSG is
         # as close as possible to the 48MB limit.
@@ -314,7 +315,6 @@ async def test_bulk_max_message_size(self):
             docs.append({"_id": i})
         result = await self.coll.insert_many(docs)
         self.assertEqual(len(docs), len(result.inserted_ids))
-        await self.coll.delete_many({})
 
     async def test_generator_insert(self):
         def gen():

test/asynchronous/test_client.py

@@ -1849,7 +1849,6 @@ async def test_network_error_message(self):
             expected = "{}:{}: ".format(*(await client.address))
             with self.assertRaisesRegex(AutoReconnect, expected):
                 await client.pymongo_test.test.find_one({})
-            print("woo!")
 
     @unittest.skipIf("PyPy" in sys.version, "PYTHON-2938 could fail on PyPy")
     async def test_process_periodic_tasks(self):

test/asynchronous/test_retryable_writes.py

@@ -248,7 +248,6 @@ async def test_unsupported_single_statement(self):
                     event.command,
                     f"{msg} sent txnNumber with {event.command_name}",
                 )
-        print("woo!")
 
     async def test_server_selection_timeout_not_retried(self):
         """A ServerSelectionTimeoutError is not retried."""

test/test_bulk.py

@@ -301,6 +301,7 @@ def test_numerous_inserts(self):
 
     def test_bulk_max_message_size(self):
         self.coll.delete_many({})
+        self.addCleanup(self.coll.delete_many, {})
         _16_MB = 16 * 1000 * 1000
         # Generate a list of documents such that the first batched OP_MSG is
         # as close as possible to the 48MB limit.
@@ -314,7 +315,6 @@ def test_bulk_max_message_size(self):
             docs.append({"_id": i})
         result = self.coll.insert_many(docs)
         self.assertEqual(len(docs), len(result.inserted_ids))
-        self.coll.delete_many({})
 
     def test_generator_insert(self):
         def gen():

test/test_client.py

@@ -1806,7 +1806,6 @@ def test_network_error_message(self):
             expected = "{}:{}: ".format(*(client.address))
             with self.assertRaisesRegex(AutoReconnect, expected):
                 client.pymongo_test.test.find_one({})
-            print("woo!")
 
     @unittest.skipIf("PyPy" in sys.version, "PYTHON-2938 could fail on PyPy")
     def test_process_periodic_tasks(self):

test/test_retryable_writes.py

@@ -246,7 +246,6 @@ def test_unsupported_single_statement(self):
                     event.command,
                     f"{msg} sent txnNumber with {event.command_name}",
                 )
-        print("woo!")
 
     def test_server_selection_timeout_not_retried(self):
         """A ServerSelectionTimeoutError is not retried."""