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({})