We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent a2e6764 commit 9107bdaCopy full SHA for 9107bda
test/asynchronous/test_concurrency.py
@@ -17,7 +17,7 @@
17
18
import asyncio
19
import time
20
-from test.asynchronous import AsyncIntegrationTest
+from test.asynchronous import AsyncIntegrationTest, async_client_context
21
from test.utils import delay
22
23
_IS_SYNC = False
@@ -27,11 +27,13 @@ class TestAsyncConcurrency(AsyncIntegrationTest):
27
async def _task(self, client):
28
await client.db.test.find_one({"$where": delay(1)})
29
30
+ # Remove once PYTHON-4636 is merged
31
+ @async_client_context.require_no_tls
32
async def test_concurrency(self):
33
tasks = []
34
iterations = 5
35
- client = self.simple_client()
36
+ client = await self.async_single_client()
37
await client.db.test.drop()
38
await client.db.test.insert_one({"x": 1})
39
0 commit comments