From 07b8f4fe8aa2ddfb07520d1404e1c1fa90d10028 Mon Sep 17 00:00:00 2001 From: Noah Stapp Date: Wed, 11 Jun 2025 12:16:06 -0400 Subject: [PATCH 1/2] PYTHON-5406 - Use correct client for test --- test/asynchronous/test_async_contextvars_reset.py | 8 +++----- 1 file changed, 3 insertions(+), 5 deletions(-) diff --git a/test/asynchronous/test_async_contextvars_reset.py b/test/asynchronous/test_async_contextvars_reset.py index 9b0e2dc4dc..693252e140 100644 --- a/test/asynchronous/test_async_contextvars_reset.py +++ b/test/asynchronous/test_async_contextvars_reset.py @@ -30,14 +30,12 @@ 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)") - 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({}) From ba5734f83f1b2d18832bcc791ac868d81e1b0840 Mon Sep 17 00:00:00 2001 From: Noah Stapp Date: Wed, 11 Jun 2025 12:38:43 -0400 Subject: [PATCH 2/2] Only run on 3.12+ --- test/asynchronous/test_async_contextvars_reset.py | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/test/asynchronous/test_async_contextvars_reset.py b/test/asynchronous/test_async_contextvars_reset.py index 693252e140..c6e825bbdf 100644 --- a/test/asynchronous/test_async_contextvars_reset.py +++ b/test/asynchronous/test_async_contextvars_reset.py @@ -27,8 +27,8 @@ 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)") await self.client.db.test.insert_one({"x": 1}) for server in self.client._topology._servers.values():