Remove executor closes

Author: NoahStapp

.evergreen/run-tests.sh

@@ -274,10 +274,15 @@ if [ -z "$GREEN_FRAMEWORK" ]; then
 
     # Workaround until unittest -> pytest conversion is complete
     if [ -z "$TEST_SUITES" ]; then
-      PYTEST_ARGS="$PYTEST_ARGS -m asyncio"
+      PYTEST_ARGS="-m asyncio --junitxml=xunit-results/TEST-asyncresults.xml $PYTEST_ARGS"
+      # shellcheck disable=SC2048
+      uv run ${UV_ARGS[*]} pytest $PYTEST_ARGS
+    else
+      PYTEST_ARGS="-m $TEST_SUITES and asyncio --junitxml=xunit-results/TEST-asyncresults.xml $PYTEST_ARGS"
       # shellcheck disable=SC2048
       uv run ${UV_ARGS[*]} pytest $PYTEST_ARGS
     fi
+
 else
     # shellcheck disable=SC2048
     uv run ${UV_ARGS[*]} green_framework_test.py $GREEN_FRAMEWORK -v $TEST_ARGS

pymongo/asynchronous/mongo_client.py

@@ -1561,8 +1561,6 @@ async def close(self) -> None:
         # Stop the periodic task thread and then send pending killCursor
         # requests before closing the topology.
         self._kill_cursors_executor.close()
-        if not _IS_SYNC:
-            await self._kill_cursors_executor.join()
         await self._process_kill_cursors()
         await self._topology.close()
         if self._encrypter:

pymongo/asynchronous/monitor.py

@@ -191,8 +191,6 @@ def gc_safe_close(self) -> None:
 
     async def close(self) -> None:
         self.gc_safe_close()
-        if not _IS_SYNC:
-            await self._executor.join()
         await self._rtt_monitor.close()
         # Increment the generation and maybe close the socket. If the executor
         # thread has the socket checked out, it will be closed when checked in.
@@ -460,8 +458,6 @@ def __init__(self, topology: Topology, topology_settings: TopologySettings, pool
 
     async def close(self) -> None:
         self.gc_safe_close()
-        if not _IS_SYNC:
-            await self._executor.join()
         # Increment the generation and maybe close the socket. If the executor
         # thread has the socket checked out, it will be closed when checked in.
         await self._pool.reset()

pymongo/synchronous/mongo_client.py

@@ -1555,8 +1555,6 @@ def close(self) -> None:
         # Stop the periodic task thread and then send pending killCursor
         # requests before closing the topology.
         self._kill_cursors_executor.close()
-        if not _IS_SYNC:
-            self._kill_cursors_executor.join()
         self._process_kill_cursors()
         self._topology.close()
         if self._encrypter:

pymongo/synchronous/monitor.py

@@ -191,8 +191,6 @@ def gc_safe_close(self) -> None:
 
     def close(self) -> None:
         self.gc_safe_close()
-        if not _IS_SYNC:
-            self._executor.join()
         self._rtt_monitor.close()
         # Increment the generation and maybe close the socket. If the executor
         # thread has the socket checked out, it will be closed when checked in.
@@ -460,8 +458,6 @@ def __init__(self, topology: Topology, topology_settings: TopologySettings, pool
 
     def close(self) -> None:
         self.gc_safe_close()
-        if not _IS_SYNC:
-            self._executor.join()
         # Increment the generation and maybe close the socket. If the executor
         # thread has the socket checked out, it will be closed when checked in.
         self._pool.reset()