diff --git a/pymongo/database.py b/pymongo/database.py index 2eabc596b..d78921534 100644 --- a/pymongo/database.py +++ b/pymongo/database.py @@ -248,6 +248,8 @@ class Database(object): error = self._command({"getlasterror": 1}) if error.get("err", 0) is None: return None + if error["err"] == "not master": + self.__connection._reset() return error def previous_error(self):