edit test to require sync

Author: sleepyStick

test/asynchronous/test_monitor.py

@@ -15,6 +15,7 @@
 """Test the monitor module."""
 from __future__ import annotations
 
+import asyncio
 import gc
 import subprocess
 import sys
@@ -23,7 +24,7 @@
 
 sys.path[0:0] = [""]
 
-from test.asynchronous import AsyncIntegrationTest, connected, unittest
+from test.asynchronous import AsyncIntegrationTest, async_client_context, connected, unittest
 from test.utils import (
     ServerAndTopologyEventListener,
     async_wait_until,
@@ -33,6 +34,7 @@
 
 _IS_SYNC = False
 
+
 def unregistered(ref):
     gc.collect()
     return ref not in _EXECUTORS
@@ -69,7 +71,9 @@ async def test_cleanup_executors_on_client_del(self):
             del client
 
             for ref, name in executor_refs:
-                await async_wait_until(partial(unregistered, ref), f"unregister executor: {name}", timeout=5)
+                await async_wait_until(
+                    partial(unregistered, ref), f"unregister executor: {name}", timeout=5
+                )
 
     async def test_cleanup_executors_on_client_close(self):
         client = await self.create_client()
@@ -79,12 +83,19 @@ async def test_cleanup_executors_on_client_close(self):
         await client.close()
 
         for executor in executors:
-            await async_wait_until(lambda: executor._stopped, f"closed executor: {executor._name}", timeout=5)
+            await async_wait_until(
+                lambda: executor._stopped, f"closed executor: {executor._name}", timeout=5
+            )
 
-    async def test_no_thread_start_runtime_err_on_shutdown(self):
+    @async_client_context.require_sync
+    def test_no_thread_start_runtime_err_on_shutdown(self):
         """Test we silence noisy runtime errors fired when the AsyncMongoClient spawns a new thread
         on process shutdown."""
-        command = [sys.executable, "-c", "from pymongo import AsyncMongoClient; c = AsyncMongoClient()"]
+        command = [
+            sys.executable,
+            "-c",
+            "from pymongo import AsyncMongoClient; c = AsyncMongoClient()",
+        ]
         completed_process: subprocess.CompletedProcess = subprocess.run(
             command, capture_output=True
         )

test/test_monitor.py

@@ -15,6 +15,7 @@
 """Test the monitor module."""
 from __future__ import annotations
 
+import asyncio
 import gc
 import subprocess
 import sys
@@ -23,7 +24,7 @@
 
 sys.path[0:0] = [""]
 
-from test import IntegrationTest, connected, unittest
+from test import IntegrationTest, client_context, connected, unittest
 from test.utils import (
     ServerAndTopologyEventListener,
     wait_until,
@@ -33,6 +34,7 @@
 
 _IS_SYNC = True
 
+
 def unregistered(ref):
     gc.collect()
     return ref not in _EXECUTORS
@@ -81,6 +83,7 @@ def test_cleanup_executors_on_client_close(self):
         for executor in executors:
             wait_until(lambda: executor._stopped, f"closed executor: {executor._name}", timeout=5)
 
+    @client_context.require_sync
     def test_no_thread_start_runtime_err_on_shutdown(self):
         """Test we silence noisy runtime errors fired when the MongoClient spawns a new thread
         on process shutdown."""