mongodb/mongo-python-driver
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

PYTHON-1739 Skip failing change stream test on sharded clusters (#397)

Browse Source 
(cherry picked from commit 9dcd828a0f)
This commit is contained in:
Shane Harvey 2019-02-07 16:01:32 -08:00 committed by Shane Harvey
parent 7d2095dc45
commit cd5600018e
1 changed files with 4 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
test/test_change_stream.py
View File

@ -296,13 +296,16 @@ class TestCollectionChangeStream(IntegrationTest):
change = next(change_stream)
self.assertEqual(change['_id'], change_stream._resume_token)
@client_context.require_no_mongos # PYTHON-1739
def test_raises_error_on_missing_id(self):
"""ChangeStream will raise an exception if the server response is
missing the resume token.
"""
with self.coll.watch([{'$project': {'_id': 0}}]) as change_stream:
self.coll.insert_one({})
with self.assertRaises(InvalidOperation):
# Server returns an error after SERVER-37786, otherwise pymongo
# raises an error.
with self.assertRaises((InvalidOperation, OperationFailure)):
next(change_stream)
# The cursor should now be closed.
with self.assertRaises(StopIteration):