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 1d117c1 commit 614e22cCopy full SHA for 614e22c
test/test_csot.py
@@ -76,10 +76,10 @@ def test_timeout_nested(self):
76
@client_context.require_change_streams
77
def test_change_stream_can_resume_after_timeouts(self):
78
coll = self.db.test
79
- with coll.watch(max_await_time_ms=150) as stream:
+ with coll.watch() as stream:
80
with pymongo.timeout(0.1):
81
with self.assertRaises(PyMongoError) as ctx:
82
- stream.try_next()
+ stream.next()
83
self.assertTrue(ctx.exception.timeout)
84
self.assertTrue(stream.alive)
85
0 commit comments