def _resume(self):
        """Reestablish this change stream after a resumable error."""
        try:
            self._cursor.close()
        except PyMongoError:
            pass
        self._cursor = self._create_cursor()
Reestablish this change stream after a resumable error.
stackoverflow/venv/lib/python3.6/site-packages/pymongo/change_stream.py