|
61 | 61 | from bson import encode |
62 | 62 | from gridfs import AsyncGridFSBucket |
63 | 63 | from pymongo import ( |
64 | | - AsyncMongoClient, |
65 | 64 | DeleteOne, |
66 | 65 | InsertOne, |
67 | 66 | ReplaceOne, |
@@ -217,14 +216,12 @@ async def do_task(self): |
217 | 216 | class TestRunCommand8Tasks(TestRunCommand): |
218 | 217 | n_tasks = 8 |
219 | 218 |
|
220 | | - async def do_task(self): |
221 | | - command = self.client.perftest.command |
222 | | - await asyncio.gather(*[command("hello", True) for _ in range(NUM_DOCS)]) |
223 | | - |
224 | 219 |
|
225 | 220 | class TestRunCommand80Tasks(TestRunCommand): |
226 | 221 | n_tasks = 80 |
227 | 222 |
|
| 223 | + |
| 224 | +class TestRunCommandManyTasks(TestRunCommand): |
228 | 225 | async def do_task(self): |
229 | 226 | command = self.client.perftest.command |
230 | 227 | await asyncio.gather(*[command("hello", True) for _ in range(NUM_DOCS)]) |
@@ -281,14 +278,12 @@ async def do_task(self): |
281 | 278 | class TestFindOneByID8Tasks(TestFindOneByID): |
282 | 279 | n_tasks = 8 |
283 | 280 |
|
284 | | - async def do_task(self): |
285 | | - find_one = self.corpus.find_one |
286 | | - await asyncio.gather(*[find_one({"_id": _id}) for _id in self.inserted_ids]) |
287 | | - |
288 | 281 |
|
289 | 282 | class TestFindOneByID80Tasks(TestFindOneByID): |
290 | 283 | n_tasks = 80 |
291 | 284 |
|
| 285 | + |
| 286 | +class TestFindOneByIDManyTasks(TestFindOneByID): |
292 | 287 | async def do_task(self): |
293 | 288 | find_one = self.corpus.find_one |
294 | 289 | await asyncio.gather(*[find_one({"_id": _id}) for _id in self.inserted_ids]) |
@@ -348,6 +343,10 @@ class TestFindManyAndEmptyCursor80Tasks(TestFindManyAndEmptyCursor): |
348 | 343 | n_tasks = 80 |
349 | 344 |
|
350 | 345 |
|
| 346 | +class TestFindManyAndEmptyCursorManyTasks(TestFindManyAndEmptyCursor): |
| 347 | + n_tasks = 1000 |
| 348 | + |
| 349 | + |
351 | 350 | class TestSmallDocBulkInsert(SmallDocInsertTest, AsyncPyMongoTestCase): |
352 | 351 | async def do_task(self): |
353 | 352 | await self.corpus.insert_many(self.documents, ordered=True) |
|
0 commit comments