|
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