File tree Expand file tree Collapse file tree 2 files changed +4
-4
lines changed Expand file tree Collapse file tree 2 files changed +4
-4
lines changed Original file line number Diff line number Diff line change @@ -1462,9 +1462,9 @@ async def test_command_cursor_to_list_csot_applied(self):
1462
1462
fail_command = {
1463
1463
"configureFailPoint" : "failCommand" ,
1464
1464
"mode" : {"times" : 1 },
1465
- "data" : {"failCommands" : ["aggregate " ], "blockTimeMS" : 10000 },
1465
+ "data" : {"failCommands" : ["getMore " ], "blockTimeMS" : 10000 },
1466
1466
}
1467
- cursor = await client .db .test .aggregate ([{ "$changeStream" : {}}] )
1467
+ cursor = await client .db .test .aggregate ([], batchSize = 5 )
1468
1468
async with self .fail_point (fail_command ):
1469
1469
with self .assertRaises (PyMongoError ) as ctx :
1470
1470
await cursor .to_list ()
Original file line number Diff line number Diff line change @@ -1453,9 +1453,9 @@ def test_command_cursor_to_list_csot_applied(self):
1453
1453
fail_command = {
1454
1454
"configureFailPoint" : "failCommand" ,
1455
1455
"mode" : {"times" : 1 },
1456
- "data" : {"failCommands" : ["aggregate " ], "blockTimeMS" : 10000 },
1456
+ "data" : {"failCommands" : ["getMore " ], "blockTimeMS" : 10000 },
1457
1457
}
1458
- cursor = client .db .test .aggregate ([{ "$changeStream" : {}}] )
1458
+ cursor = client .db .test .aggregate ([], batchSize = 5 )
1459
1459
with self .fail_point (fail_command ):
1460
1460
with self .assertRaises (PyMongoError ) as ctx :
1461
1461
cursor .to_list ()
You can’t perform that action at this time.
0 commit comments