ahh i need to trigger garbage collect

Author: sleepyStick

test/asynchronous/test_monitor.py

@@ -76,23 +76,19 @@ async def test_cleanup_executors_on_client_del(self):
                 )
 
             def resource_warning_caught():
-                count = 0
+                gc.collect()
+                print(w)
                 for warning in w:
+                    print(warning)
                     if (
                         issubclass(warning.category, ResourceWarning)
                         and "Call AsyncMongoClient.close() to safely shut down your client and free up resources."
                         in str(warning.message)
                     ):
-                        count += 1
-                return count >= 2
+                        return True
+                return False
 
-            try:
-                await async_wait_until(
-                    resource_warning_caught, "catch resource warning", timeout=30
-                )
-            except AssertionError as exc:
-                if "catch resource warning" not in str(exc):
-                    raise
+            await async_wait_until(resource_warning_caught, "catch resource warning")
 
     async def test_cleanup_executors_on_client_close(self):
         client = await self.create_client()

test/test_monitor.py

@@ -74,21 +74,19 @@ def test_cleanup_executors_on_client_del(self):
                 wait_until(partial(unregistered, ref), f"unregister executor: {name}", timeout=5)
 
             def resource_warning_caught():
-                count = 0
+                gc.collect()
+                print(w)
                 for warning in w:
+                    print(warning)
                     if (
                         issubclass(warning.category, ResourceWarning)
                         and "Call MongoClient.close() to safely shut down your client and free up resources."
                         in str(warning.message)
                     ):
-                        count += 1
-                return count >= 2
-
-            try:
-                wait_until(resource_warning_caught, "catch resource warning", timeout=30)
-            except AssertionError as exc:
-                if "catch resource warning" not in str(exc):
-                    raise
+                        return True
+                return False
+
+            wait_until(resource_warning_caught, "catch resource warning")
 
     def test_cleanup_executors_on_client_close(self):
         client = self.create_client()