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 b021ede commit 469013bCopy full SHA for 469013b
test/asynchronous/test_csot.py
@@ -103,7 +103,7 @@ async def test_change_stream_can_resume_after_timeouts(self):
103
await stream.try_next()
104
await coll.insert_one({})
105
with pymongo.timeout(10):
106
- self.assertTrue(stream.next())
+ self.assertTrue(await stream.next())
107
self.assertTrue(stream.alive)
108
# Timeout applies to entire next() call, not only individual commands.
109
with pymongo.timeout(0.5):
0 commit comments