address teardown failures in data lake tests

Author: blink1073

test/asynchronous/test_data_lake.py

@@ -80,17 +80,20 @@ async def test_1(self):
         self.assertEqual(cursor_ns, target_ns)
 
         self.assertIn(cursor_id, succeeded.reply["cursorsKilled"])
+        await client.close()
 
     # Test no auth
     async def test_2(self):
         client = await self.async_rs_client_noauth()
         await client.admin.command("ping")
+        await client.close()
 
     # Test with auth
     async def test_3(self):
         for mechanism in ["SCRAM-SHA-1", "SCRAM-SHA-256"]:
             client = await self.async_rs_or_single_client(authMechanism=mechanism)
             await client[self.TEST_DB][self.TEST_COLLECTION].find_one()
+            await client.close()
 
 
 # Location of JSON test specifications.

test/test_data_lake.py

@@ -80,17 +80,20 @@ def test_1(self):
         self.assertEqual(cursor_ns, target_ns)
 
         self.assertIn(cursor_id, succeeded.reply["cursorsKilled"])
+        client.close()
 
     # Test no auth
     def test_2(self):
         client = self.rs_client_noauth()
         client.admin.command("ping")
+        client.close()
 
     # Test with auth
     def test_3(self):
         for mechanism in ["SCRAM-SHA-1", "SCRAM-SHA-256"]:
             client = self.rs_or_single_client(authMechanism=mechanism)
             client[self.TEST_DB][self.TEST_COLLECTION].find_one()
+            client.close()
 
 
 # Location of JSON test specifications.