From 8fddccf2b2e597bbe0a466ea5375c5b5a715cdde Mon Sep 17 00:00:00 2001 From: Noah Stapp Date: Wed, 11 Jun 2025 13:45:54 -0400 Subject: [PATCH] PYTHON-5406 - Use correct client for test (#2377) (cherry picked from commit 8a8cb6f0afb7d93c5159e0fb89d89740e5f9932e) --- test/asynchronous/test_async_contextvars_reset.py | 12 +++++------- 1 file changed, 5 insertions(+), 7 deletions(-) diff --git a/test/asynchronous/test_async_contextvars_reset.py b/test/asynchronous/test_async_contextvars_reset.py index 9b0e2dc4dc..c6e825bbdf 100644 --- a/test/asynchronous/test_async_contextvars_reset.py +++ b/test/asynchronous/test_async_contextvars_reset.py @@ -27,17 +27,15 @@ class TestAsyncContextVarsReset(AsyncIntegrationTest): async def test_context_vars_are_reset_in_executor(self): - if sys.version_info < (3, 11): - self.skipTest("Test requires asyncio.Task.get_context (added in Python 3.11)") + if sys.version_info < (3, 12): + self.skipTest("Test requires asyncio.Task.get_context (added in Python 3.12)") - client = self.simple_client() - - await client.db.test.insert_one({"x": 1}) - for server in client._topology._servers.values(): + await self.client.db.test.insert_one({"x": 1}) + for server in self.client._topology._servers.values(): for context in [ c for c in server._monitor._executor._task.get_context() if c.name in ["TIMEOUT", "RTT", "DEADLINE"] ]: self.assertIn(context.get(), [None, float("inf"), 0.0]) - await client.db.test.delete_many({}) + await self.client.db.test.delete_many({})