Skip to content

Commit dd23624

Browse files
committed
handle None case
1 parent 14cecab commit dd23624

File tree

1 file changed

+2
-0
lines changed

1 file changed

+2
-0
lines changed

pymongo/change_stream.py

+2
Original file line numberDiff line numberDiff line change
@@ -302,6 +302,8 @@ def try_next(self):
302302
self._resume()
303303
change = self._cursor._try_next(False)
304304
except OperationFailure as exc:
305+
if exc._max_wire_version is None:
306+
raise
305307
is_resumable = ((exc._max_wire_version >= 9 and
306308
exc.has_error_label("ResumableChangeStreamError")) or
307309
(exc._max_wire_version < 9 and

0 commit comments

Comments
 (0)