Detailed error message for better debugging

bson/__init__.py

@@ -1386,7 +1386,7 @@ def is_valid(bson: bytes) -> bool:
     :param bson: the data to be validated
     """
     if not isinstance(bson, bytes):
-        raise TypeError("BSON data must be an instance of a subclass of bytes")
+        raise TypeError(f"BSON data must be an instance of a subclass of bytes, not {type(bson)}")
 
     try:
         _bson_to_dict(bson, DEFAULT_CODEC_OPTIONS)

bson/binary.py

@@ -290,9 +290,9 @@ def __new__(
         subtype: int = BINARY_SUBTYPE,
     ) -> Binary:
         if not isinstance(subtype, int):
-            raise TypeError("subtype must be an instance of int")
+            raise TypeError(f"subtype must be an instance of int, not {type(subtype)}")
         if subtype >= 256 or subtype < 0:
-            raise ValueError("subtype must be contained in [0, 256)")
+            raise ValueError(f"subtype must be contained in [0, 256), instead got {subtype}")
         # Support any type that implements the buffer protocol.
         self = bytes.__new__(cls, memoryview(data).tobytes())
         self.__subtype = subtype
@@ -321,7 +321,7 @@ def from_uuid(
         .. versionadded:: 3.11
         """
         if not isinstance(uuid, UUID):
-            raise TypeError("uuid must be an instance of uuid.UUID")
+            raise TypeError(f"uuid must be an instance of uuid.UUID, not {type(uuid)}")
 
         if uuid_representation not in ALL_UUID_REPRESENTATIONS:
             raise ValueError(

bson/code.py

@@ -56,7 +56,7 @@ def __new__(
         **kwargs: Any,
     ) -> Code:
         if not isinstance(code, str):
-            raise TypeError("code must be an instance of str")
+            raise TypeError(f"code must be an instance of str, not {type(code)}")
 
         self = str.__new__(cls, code)
 
@@ -67,7 +67,7 @@ def __new__(
 
         if scope is not None:
             if not isinstance(scope, _Mapping):
-                raise TypeError("scope must be an instance of dict")
+                raise TypeError(f"scope must be an instance of dict, not {type(scope)}")
             if self.__scope is not None:
                 self.__scope.update(scope)  # type: ignore
             else:

bson/codec_options.py

@@ -401,17 +401,18 @@ def __new__(
                     "uuid_representation must be a value from bson.binary.UuidRepresentation"
                 )
             if not isinstance(unicode_decode_error_handler, str):
-                raise ValueError("unicode_decode_error_handler must be a string")
+                raise ValueError(
+                    f"unicode_decode_error_handler must be a string, not {type(unicode_decode_error_handler)}")
             if tzinfo is not None:
                 if not isinstance(tzinfo, datetime.tzinfo):
-                    raise TypeError("tzinfo must be an instance of datetime.tzinfo")
+                    raise TypeError(f"tzinfo must be an instance of datetime.tzinfo, not {type(tzinfo)}")
                 if not tz_aware:
                     raise ValueError("cannot specify tzinfo without also setting tz_aware=True")
 
             type_registry = type_registry or TypeRegistry()
 
             if not isinstance(type_registry, TypeRegistry):
-                raise TypeError("type_registry must be an instance of TypeRegistry")
+                raise TypeError(f"type_registry must be an instance of TypeRegistry, not {type(type_registry)}")
 
             return tuple.__new__(
                 cls,
@@ -482,7 +483,6 @@ def with_options(self, **kwargs: Any) -> CodecOptions:
             opts.update(kwargs)
             return CodecOptions(**opts)
 
-
 DEFAULT_CODEC_OPTIONS: CodecOptions[dict[str, Any]] = CodecOptions()
 
 

bson/dbref.py

@@ -56,9 +56,9 @@ def __init__(
         .. seealso:: The MongoDB documentation on `dbrefs <https://dochub.mongodb.org/core/dbrefs>`_.
         """
         if not isinstance(collection, str):
-            raise TypeError("collection must be an instance of str")
+            raise TypeError(f"collection must be an instance of str, not {type(collection)}")
         if database is not None and not isinstance(database, str):
-            raise TypeError("database must be an instance of str")
+            raise TypeError(f"database must be an instance of str, not {type(database)}")
 
         self.__collection = collection
         self.__id = id

bson/decimal128.py

@@ -277,7 +277,7 @@ def from_bid(cls: Type[Decimal128], value: bytes) -> Decimal128:
             point in Binary Integer Decimal (BID) format).
         """
         if not isinstance(value, bytes):
-            raise TypeError("value must be an instance of bytes")
+            raise TypeError(f"value must be an instance of bytes, not {type(value)}")
         if len(value) != 16:
             raise ValueError("value must be exactly 16 bytes")
         return cls((_UNPACK_64(value[8:])[0], _UNPACK_64(value[:8])[0]))  # type: ignore

bson/timestamp.py

@@ -58,9 +58,9 @@ def __init__(self, time: Union[datetime.datetime, int], inc: int) -> None:
                 time = time - offset
             time = int(calendar.timegm(time.timetuple()))
         if not isinstance(time, int):
-            raise TypeError("time must be an instance of int")
+            raise TypeError(f"time must be an instance of int, not {type(time)}")
         if not isinstance(inc, int):
-            raise TypeError("inc must be an instance of int")
+            raise TypeError(f"inc must be an instance of int, not {type(inc)}")
         if not 0 <= time < UPPERBOUND:
             raise ValueError("time must be contained in [0, 2**32)")
         if not 0 <= inc < UPPERBOUND:

gridfs/asynchronous/grid_file.py

@@ -100,7 +100,7 @@ def __init__(self, database: AsyncDatabase, collection: str = "fs"):
         .. seealso:: The MongoDB documentation on `gridfs <https://dochub.mongodb.org/core/gridfs>`_.
         """
         if not isinstance(database, AsyncDatabase):
-            raise TypeError("database must be an instance of Database")
+            raise TypeError(f"database must be an instance of Database, not {type(database)}")
 
         database = _clear_entity_type_registry(database)
 
@@ -503,7 +503,7 @@ def __init__(
         .. seealso:: The MongoDB documentation on `gridfs <https://dochub.mongodb.org/core/gridfs>`_.
         """
         if not isinstance(db, AsyncDatabase):
-            raise TypeError("database must be an instance of AsyncDatabase")
+            raise TypeError(f"database must be an instance of AsyncDatabase, not {type(db)}")
 
         db = _clear_entity_type_registry(db)
 
@@ -1082,7 +1082,7 @@ def __init__(
            :attr:`~pymongo.collection.AsyncCollection.write_concern`
         """
         if not isinstance(root_collection, AsyncCollection):
-            raise TypeError("root_collection must be an instance of AsyncCollection")
+            raise TypeError(f"root_collection must be an instance of AsyncCollection, not {type(root_collection)}")
 
         if not root_collection.write_concern.acknowledged:
             raise ConfigurationError("root_collection must use acknowledged write_concern")
@@ -1436,7 +1436,7 @@ def __init__(
            from the server. Metadata is fetched when first needed.
         """
         if not isinstance(root_collection, AsyncCollection):
-            raise TypeError("root_collection must be an instance of AsyncCollection")
+            raise TypeError(f"root_collection must be an instance of AsyncCollection, not {type(root_collection)}")
         _disallow_transactions(session)
 
         root_collection = _clear_entity_type_registry(root_collection)

gridfs/synchronous/grid_file.py

@@ -100,7 +100,7 @@ def __init__(self, database: Database, collection: str = "fs"):
         .. seealso:: The MongoDB documentation on `gridfs <https://dochub.mongodb.org/core/gridfs>`_.
         """
         if not isinstance(database, Database):
-            raise TypeError("database must be an instance of Database")
+            raise TypeError(f"database must be an instance of Database, not {type(database)}")
 
         database = _clear_entity_type_registry(database)
 
@@ -501,7 +501,7 @@ def __init__(
         .. seealso:: The MongoDB documentation on `gridfs <https://dochub.mongodb.org/core/gridfs>`_.
         """
         if not isinstance(db, Database):
-            raise TypeError("database must be an instance of Database")
+            raise TypeError(f"database must be an instance of Database, not {type(db)}")
 
         db = _clear_entity_type_registry(db)
 
@@ -1426,7 +1426,7 @@ def __init__(
            from the server. Metadata is fetched when first needed.
         """
         if not isinstance(root_collection, Collection):
-            raise TypeError("root_collection must be an instance of Collection")
+            raise TypeError(f"root_collection must be an instance of Collection, not {type(root_collection)}")
         _disallow_transactions(session)
 
         root_collection = _clear_entity_type_registry(root_collection)

pymongo/__init__.py

@@ -160,7 +160,7 @@ def timeout(seconds: Optional[float]) -> ContextManager[None]:
     .. versionadded:: 4.2
     """
     if not isinstance(seconds, (int, float, type(None))):
-        raise TypeError("timeout must be None, an int, or a float")
+        raise TypeError(f"timeout must be None, an int, or a float, not {type(seconds)}")
     if seconds and seconds < 0:
         raise ValueError("timeout cannot be negative")
     if seconds is not None:

pymongo/asynchronous/auth.py

@@ -161,7 +161,7 @@ def _password_digest(username: str, password: str) -> str:
     if len(password) == 0:
         raise ValueError("password can't be empty")
     if not isinstance(username, str):
-        raise TypeError("username must be an instance of str")
+        raise TypeError(f"username must be an instance of str, not {type(username)}")
 
     md5hash = hashlib.md5()  # noqa: S324
     data = f"{username}:mongo:{password}"

pymongo/asynchronous/auth_oidc.py

@@ -213,7 +213,7 @@ def _get_access_token(self) -> Optional[str]:
                 )
                 resp = cb.fetch(context)
                 if not isinstance(resp, OIDCCallbackResult):
-                    raise ValueError("Callback result must be of type OIDCCallbackResult")
+                    raise ValueError(f"Callback result must be of type OIDCCallbackResult, not {type(resp)}")
                 self.refresh_token = resp.refresh_token
                 self.access_token = resp.access_token
                 self.token_gen_id += 1

pymongo/asynchronous/collection.py

@@ -228,7 +228,7 @@ def __init__(
             read_concern or database.read_concern,
         )
         if not isinstance(name, str):
-            raise TypeError("name must be an instance of str")
+            raise TypeError(f"name must be an instance of str, not {type(name)}")
         from pymongo.asynchronous.database import AsyncDatabase
 
         if not isinstance(database, AsyncDatabase):
@@ -2475,7 +2475,7 @@ async def _drop_index(
             name = helpers_shared._gen_index_name(index_or_name)
 
         if not isinstance(name, str):
-            raise TypeError("index_or_name must be an instance of str or list")
+            raise TypeError(f"index_or_name must be an instance of str or list, not {type(name)}")
 
         cmd = {"dropIndexes": self._name, "index": name}
         cmd.update(kwargs)
@@ -3078,7 +3078,7 @@ async def rename(
 
         """
         if not isinstance(new_name, str):
-            raise TypeError("new_name must be an instance of str")
+            raise TypeError(f"new_name must be an instance of str, not {type(new_name)}")
 
         if not new_name or ".." in new_name:
             raise InvalidName("collection names cannot be empty")
@@ -3148,7 +3148,7 @@ async def distinct(
 
         """
         if not isinstance(key, str):
-            raise TypeError("key must be an instance of str")
+            raise TypeError(f"key must be an instance of str, not {type(key)}")
         cmd = {"distinct": self._name, "key": key}
         if filter is not None:
             if "query" in kwargs:
@@ -3196,7 +3196,7 @@ async def _find_and_modify(
         common.validate_is_mapping("filter", filter)
         if not isinstance(return_document, bool):
             raise ValueError(
-                "return_document must be ReturnDocument.BEFORE or ReturnDocument.AFTER"
+                f"return_document must be ReturnDocument.BEFORE or ReturnDocument.AFTER, not {type(return_document)}"
             )
         collation = validate_collation_or_none(kwargs.pop("collation", None))
         cmd = {"findAndModify": self._name, "query": filter, "new": return_document}

pymongo/asynchronous/command_cursor.py

@@ -94,7 +94,7 @@ def __init__(
         self.batch_size(batch_size)
 
         if not isinstance(max_await_time_ms, int) and max_await_time_ms is not None:
-            raise TypeError("max_await_time_ms must be an integer or None")
+            raise TypeError(f"max_await_time_ms must be an integer or None, not {type(max_await_time_ms)}")
 
     def __del__(self) -> None:
         self._die_no_lock()
@@ -115,7 +115,7 @@ def batch_size(self, batch_size: int) -> AsyncCommandCursor[_DocumentType]:
         :param batch_size: The size of each batch of results requested.
         """
         if not isinstance(batch_size, int):
-            raise TypeError("batch_size must be an integer")
+            raise TypeError(f"batch_size must be an integer, not {type(batch_size)}")
         if batch_size < 0:
             raise ValueError("batch_size must be >= 0")
 

pymongo/asynchronous/cursor.py

@@ -146,9 +146,9 @@ def __init__(
         spec: Mapping[str, Any] = filter or {}
         validate_is_mapping("filter", spec)
         if not isinstance(skip, int):
-            raise TypeError("skip must be an instance of int")
+            raise TypeError(f"skip must be an instance of int, not {type(skip)}")
         if not isinstance(limit, int):
-            raise TypeError("limit must be an instance of int")
+            raise TypeError(f"limit must be an instance of int, not {type(limit)}")
         validate_boolean("no_cursor_timeout", no_cursor_timeout)
         if no_cursor_timeout and not self._explicit_session:
             warnings.warn(
@@ -171,7 +171,7 @@ def __init__(
         validate_boolean("allow_partial_results", allow_partial_results)
         validate_boolean("oplog_replay", oplog_replay)
         if not isinstance(batch_size, int):
-            raise TypeError("batch_size must be an integer")
+            raise TypeError(f"batch_size must be an integer, not {type(batch_size)}")
         if batch_size < 0:
             raise ValueError("batch_size must be >= 0")
         # Only set if allow_disk_use is provided by the user, else None.
@@ -388,7 +388,7 @@ async def add_option(self, mask: int) -> AsyncCursor[_DocumentType]:
         cursor.add_option(2)
         """
         if not isinstance(mask, int):
-            raise TypeError("mask must be an int")
+            raise TypeError(f"mask must be an int, not {type(mask)}")
         self._check_okay_to_chain()
 
         if mask & _QUERY_OPTIONS["exhaust"]:
@@ -408,7 +408,7 @@ def remove_option(self, mask: int) -> AsyncCursor[_DocumentType]:
         cursor.remove_option(2)
         """
         if not isinstance(mask, int):
-            raise TypeError("mask must be an int")
+            raise TypeError(f"mask must be an int, not {type(mask)}")
         self._check_okay_to_chain()
 
         if mask & _QUERY_OPTIONS["exhaust"]:
@@ -432,7 +432,7 @@ def allow_disk_use(self, allow_disk_use: bool) -> AsyncCursor[_DocumentType]:
         .. versionadded:: 3.11
         """
         if not isinstance(allow_disk_use, bool):
-            raise TypeError("allow_disk_use must be a bool")
+            raise TypeError(f"allow_disk_use must be a bool, not {type(allow_disk_use)}")
         self._check_okay_to_chain()
 
         self._allow_disk_use = allow_disk_use
@@ -451,7 +451,7 @@ def limit(self, limit: int) -> AsyncCursor[_DocumentType]:
         .. seealso:: The MongoDB documentation on `limit <https://dochub.mongodb.org/core/limit>`_.
         """
         if not isinstance(limit, int):
-            raise TypeError("limit must be an integer")
+            raise TypeError(f"limit must be an integer, not {type(limit)}")
         if self._exhaust:
             raise InvalidOperation("Can't use limit and exhaust together.")
         self._check_okay_to_chain()
@@ -479,7 +479,7 @@ def batch_size(self, batch_size: int) -> AsyncCursor[_DocumentType]:
         :param batch_size: The size of each batch of results requested.
         """
         if not isinstance(batch_size, int):
-            raise TypeError("batch_size must be an integer")
+            raise TypeError(f"batch_size must be an integer, not {type(batch_size)}")
         if batch_size < 0:
             raise ValueError("batch_size must be >= 0")
         self._check_okay_to_chain()
@@ -499,7 +499,7 @@ def skip(self, skip: int) -> AsyncCursor[_DocumentType]:
         :param skip: the number of results to skip
         """
         if not isinstance(skip, int):
-            raise TypeError("skip must be an integer")
+            raise TypeError(f"skip must be an integer, not {type(skip)}")
         if skip < 0:
             raise ValueError("skip must be >= 0")
         self._check_okay_to_chain()
@@ -520,7 +520,7 @@ def max_time_ms(self, max_time_ms: Optional[int]) -> AsyncCursor[_DocumentType]:
         :param max_time_ms: the time limit after which the operation is aborted
         """
         if not isinstance(max_time_ms, int) and max_time_ms is not None:
-            raise TypeError("max_time_ms must be an integer or None")
+            raise TypeError(f"max_time_ms must be an integer or None, not {type(max_time_ms)}")
         self._check_okay_to_chain()
 
         self._max_time_ms = max_time_ms
@@ -543,7 +543,7 @@ def max_await_time_ms(self, max_await_time_ms: Optional[int]) -> AsyncCursor[_Do
         .. versionadded:: 3.2
         """
         if not isinstance(max_await_time_ms, int) and max_await_time_ms is not None:
-            raise TypeError("max_await_time_ms must be an integer or None")
+            raise TypeError(f"max_await_time_ms must be an integer or None, not {type(max_await_time_ms)}")
         self._check_okay_to_chain()
 
         # Ignore max_await_time_ms if not tailable or await_data is False.
@@ -679,7 +679,7 @@ def max(self, spec: _Sort) -> AsyncCursor[_DocumentType]:
         .. versionadded:: 2.7
         """
         if not isinstance(spec, (list, tuple)):
-            raise TypeError("spec must be an instance of list or tuple")
+            raise TypeError(f"spec must be an instance of list or tuple, not {type(spec)}")
 
         self._check_okay_to_chain()
         self._max = dict(spec)
@@ -701,7 +701,7 @@ def min(self, spec: _Sort) -> AsyncCursor[_DocumentType]:
         .. versionadded:: 2.7
         """
         if not isinstance(spec, (list, tuple)):
-            raise TypeError("spec must be an instance of list or tuple")
+            raise TypeError(f"spec must be an instance of list or tuple, not {type(spec)}")
 
         self._check_okay_to_chain()
         self._min = dict(spec)