Skip to content
Merged
Changes from 1 commit
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
8 changes: 3 additions & 5 deletions test/asynchronous/test_async_contextvars_reset.py
Original file line number Diff line number Diff line change
Expand Up @@ -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({})
Loading