Detailed error message for better debugging

Author: tejaschauhan36912

bson/codec_options.py

@@ -402,17 +402,22 @@ def __new__(
                 )
             if not isinstance(unicode_decode_error_handler, str):
                 raise ValueError(
-                    f"unicode_decode_error_handler must be a string, not {type(unicode_decode_error_handler)}")
+                    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(f"tzinfo must be an instance of datetime.tzinfo, not {type(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(f"type_registry must be an instance of TypeRegistry, not {type(type_registry)}")
+                raise TypeError(
+                    f"type_registry must be an instance of TypeRegistry, not {type(type_registry)}"
+                )
 
             return tuple.__new__(
                 cls,
@@ -483,6 +488,7 @@ def with_options(self, **kwargs: Any) -> CodecOptions:
             opts.update(kwargs)
             return CodecOptions(**opts)
 
+
 DEFAULT_CODEC_OPTIONS: CodecOptions[dict[str, Any]] = CodecOptions()
 
 

gridfs/asynchronous/grid_file.py

@@ -1082,7 +1082,9 @@ def __init__(
            :attr:`~pymongo.collection.AsyncCollection.write_concern`
         """
         if not isinstance(root_collection, AsyncCollection):
-            raise TypeError(f"root_collection must be an instance of AsyncCollection, not {type(root_collection)}")
+            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 +1438,9 @@ def __init__(
            from the server. Metadata is fetched when first needed.
         """
         if not isinstance(root_collection, AsyncCollection):
-            raise TypeError(f"root_collection must be an instance of AsyncCollection, not {type(root_collection)}")
+            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

@@ -1426,7 +1426,9 @@ def __init__(
            from the server. Metadata is fetched when first needed.
         """
         if not isinstance(root_collection, Collection):
-            raise TypeError(f"root_collection must be an instance of Collection, not {type(root_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/asynchronous/auth_oidc.py

@@ -213,7 +213,9 @@ def _get_access_token(self) -> Optional[str]:
                 )
                 resp = cb.fetch(context)
                 if not isinstance(resp, OIDCCallbackResult):
-                    raise ValueError(f"Callback result must be of type OIDCCallbackResult, not {type(resp)}")
+                    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/client_session.py

@@ -310,7 +310,9 @@ def __init__(
                 )
         if max_commit_time_ms is not None:
             if not isinstance(max_commit_time_ms, int):
-                raise TypeError("max_commit_time_ms must be an integer or None")
+                raise TypeError(
+                    f"max_commit_time_ms must be an integer or None, not {type(max_commit_time_ms)}"
+                )
 
     @property
     def read_concern(self) -> Optional[ReadConcern]:
@@ -902,7 +904,9 @@ def advance_cluster_time(self, cluster_time: Mapping[str, Any]) -> None:
             another `AsyncClientSession` instance.
         """
         if not isinstance(cluster_time, _Mapping):
-            raise TypeError("cluster_time must be a subclass of collections.Mapping")
+            raise TypeError(
+                f"cluster_time must be a subclass of collections.Mapping, not {type(cluster_time)}"
+            )
         if not isinstance(cluster_time.get("clusterTime"), Timestamp):
             raise ValueError("Invalid cluster_time")
         self._advance_cluster_time(cluster_time)
@@ -923,7 +927,9 @@ def advance_operation_time(self, operation_time: Timestamp) -> None:
             another `AsyncClientSession` instance.
         """
         if not isinstance(operation_time, Timestamp):
-            raise TypeError("operation_time must be an instance of bson.timestamp.Timestamp")
+            raise TypeError(
+                f"operation_time must be an instance of bson.timestamp.Timestamp, not {type(operation_time)}"
+            )
         self._advance_operation_time(operation_time)
 
     def _process_response(self, reply: Mapping[str, Any]) -> None:

pymongo/asynchronous/command_cursor.py

@@ -94,7 +94,9 @@ 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(f"max_await_time_ms must be an integer or None, not {type(max_await_time_ms)}")
+            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()

pymongo/asynchronous/cursor.py

@@ -543,7 +543,9 @@ 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(f"max_await_time_ms must be an integer or None, not {type(max_await_time_ms)}")
+            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.

pymongo/asynchronous/database.py

@@ -1374,7 +1374,9 @@ async def validate_collection(
             name = name.name
 
         if not isinstance(name, str):
-            raise TypeError(f"name_or_collection must be an instance of str or AsyncCollection, not {type(name)}")
+            raise TypeError(
+                f"name_or_collection must be an instance of str or AsyncCollection, not {type(name)}"
+            )
         cmd = {"validate": name, "scandata": scandata, "full": full}
         if comment is not None:
             cmd["comment"] = comment

pymongo/asynchronous/encryption.py

@@ -322,7 +322,9 @@ async def insert_data_key(self, data_key: bytes) -> Binary:
         raw_doc = RawBSONDocument(data_key, _KEY_VAULT_OPTS)
         data_key_id = raw_doc.get("_id")
         if not isinstance(data_key_id, Binary) or data_key_id.subtype != UUID_SUBTYPE:
-            raise TypeError(f"data_key _id must be Binary with a UUID subtype, not {type(data_key_id)}")
+            raise TypeError(
+                f"data_key _id must be Binary with a UUID subtype, not {type(data_key_id)}"
+            )
 
         assert self.key_vault_coll is not None
         await self.key_vault_coll.insert_one(raw_doc)
@@ -645,7 +647,8 @@ def __init__(
 
         if not isinstance(codec_options, CodecOptions):
             raise TypeError(
-                f"codec_options must be an instance of bson.codec_options.CodecOptions, not {type(codec_options)}")
+                f"codec_options must be an instance of bson.codec_options.CodecOptions, not {type(codec_options)}"
+            )
 
         if not isinstance(key_vault_client, AsyncMongoClient):
             # This is for compatibility with mocked and subclassed types, such as in Motor.

pymongo/asynchronous/mongo_client.py

@@ -2093,7 +2093,9 @@ async def _tmp_session(
         """If provided session is None, lend a temporary session."""
         if session is not None:
             if not isinstance(session, client_session.AsyncClientSession):
-                raise ValueError(f"'session' argument must be an AsyncClientSession or None, not {type(session)}.")
+                raise ValueError(
+                    f"'session' argument must be an AsyncClientSession or None, not {type(session)}."
+                )
             # Don't call end_session.
             yield session
             return
@@ -2247,7 +2249,9 @@ async def drop_database(
             name = name.name
 
         if not isinstance(name, str):
-            raise TypeError(f"name_or_database must be an instance of str or a AsyncDatabase, not {type(name)}")
+            raise TypeError(
+                f"name_or_database must be an instance of str or a AsyncDatabase, not {type(name)}"
+            )
 
         async with await self._conn_for_writes(session, operation=_Op.DROP_DATABASE) as conn:
             await self[name]._command(