Issue:#3026 Replaced ValueError and TypeError with InvalidArgumentError

chromadb/__init__.py

@@ -188,12 +188,12 @@ def HttpClient(
 
     settings.chroma_api_impl = "chromadb.api.fastapi.FastAPI"
     if settings.chroma_server_host and settings.chroma_server_host != host:
-        raise ValueError(
+        raise InvalidArgumentError(
             f"Chroma server host provided in settings[{settings.chroma_server_host}] is different to the one provided in HttpClient: [{host}]"
         )
     settings.chroma_server_host = host
     if settings.chroma_server_http_port and settings.chroma_server_http_port != port:
-        raise ValueError(
+        raise InvalidArgumentError(
             f"Chroma server http port provided in settings[{settings.chroma_server_http_port}] is different to the one provided in HttpClient: [{port}]"
         )
     settings.chroma_server_http_port = port
@@ -239,12 +239,12 @@ async def AsyncHttpClient(
 
     settings.chroma_api_impl = "chromadb.api.async_fastapi.AsyncFastAPI"
     if settings.chroma_server_host and settings.chroma_server_host != host:
-        raise ValueError(
+        raise InvalidArgumentError(
             f"Chroma server host provided in settings[{settings.chroma_server_host}] is different to the one provided in HttpClient: [{host}]"
         )
     settings.chroma_server_host = host
     if settings.chroma_server_http_port and settings.chroma_server_http_port != port:
-        raise ValueError(
+        raise InvalidArgumentError(
             f"Chroma server http port provided in settings[{settings.chroma_server_http_port}] is different to the one provided in HttpClient: [{port}]"
         )
     settings.chroma_server_http_port = port

chromadb/api/__init__.py

@@ -99,7 +99,7 @@ def delete_collection(
             name: The name of the collection to delete.
 
         Raises:
-            ValueError: If the collection does not exist.
+            InvalidArgumentError: If the collection does not exist.
 
         Examples:
             ```python
@@ -388,8 +388,8 @@ def create_collection(
             Collection: The newly created collection.
 
         Raises:
-            ValueError: If the collection already exists and get_or_create is False.
-            ValueError: If the collection name is invalid.
+            InvalidArgumentError: If the collection already exists and get_or_create is False.
+            InvalidArgumentError: If the collection name is invalid.
 
         Examples:
             ```python
@@ -422,7 +422,7 @@ def get_collection(
             Collection: The collection
 
         Raises:
-            ValueError: If the collection does not exist
+            InvalidArgumentError: If the collection does not exist
 
         Examples:
             ```python

chromadb/api/async_api.py

@@ -91,7 +91,7 @@ async def delete_collection(
             name: The name of the collection to delete.
 
         Raises:
-            ValueError: If the collection does not exist.
+            InvalidArgumentError: If the collection does not exist.
 
         Examples:
             ```python
@@ -380,8 +380,8 @@ async def create_collection(
             Collection: The newly created collection.
 
         Raises:
-            ValueError: If the collection already exists and get_or_create is False.
-            ValueError: If the collection name is invalid.
+            InvalidArgumentError: If the collection already exists and get_or_create is False.
+            InvalidArgumentError: If the collection name is invalid.
 
         Examples:
             ```python
@@ -414,7 +414,7 @@ async def get_collection(
             Collection: The collection
 
         Raises:
-            ValueError: If the collection does not exist
+            InvalidArgumentError: If the collection does not exist
 
         Examples:
             ```python

chromadb/api/async_client.py

@@ -127,21 +127,21 @@ async def _validate_tenant_database(self, tenant: str, database: str) -> None:
         try:
             await self._admin_client.get_tenant(name=tenant)
         except httpx.ConnectError:
-            raise ValueError(
+            raise InvalidArgumentError(
                 "Could not connect to a Chroma server. Are you sure it is running?"
             )
         # Propagate ChromaErrors
         except ChromaError as e:
             raise e
         except Exception:
-            raise ValueError(
+            raise InvalidArgumentError(
                 f"Could not connect to tenant {tenant}. Are you sure it exists?"
             )
 
         try:
             await self._admin_client.get_database(name=database, tenant=tenant)
         except httpx.ConnectError:
-            raise ValueError(
+            raise InvalidArgumentError(
                 "Could not connect to a Chroma server. Are you sure it is running?"
             )
 

chromadb/api/base_http_client.py

@@ -18,11 +18,11 @@ class BaseHTTPClient:
     def _validate_host(host: str) -> None:
         parsed = urlparse(host)
         if "/" in host and parsed.scheme not in {"http", "https"}:
-            raise ValueError(
+            raise InvalidArgumentError(
                 "Invalid URL. " f"Unrecognized protocol - {parsed.scheme}."
             )
         if "/" in host and (not host.startswith("http")):
-            raise ValueError(
+            raise InvalidArgumentError(
                 "Invalid URL. "
                 "Seems that you are trying to pass URL as a host but without \
                   specifying the protocol. "

chromadb/api/client.py

@@ -100,14 +100,14 @@ def get_user_identity(self) -> UserIdentity:
         try:
             return self._server.get_user_identity()
         except httpx.ConnectError:
-            raise ValueError(
+            raise InvalidArgumentError(
                 "Could not connect to a Chroma server. Are you sure it is running?"
             )
         # Propagate ChromaErrors
         except ChromaError as e:
             raise e
         except Exception as e:
-            raise ValueError(str(e))
+            raise InvalidArgumentError(str(e))
 
     # region BaseAPI Methods
     # Note - we could do this in less verbose ways, but they break type checking
@@ -416,21 +416,21 @@ def _validate_tenant_database(self, tenant: str, database: str) -> None:
         try:
             self._admin_client.get_tenant(name=tenant)
         except httpx.ConnectError:
-            raise ValueError(
+            raise InvalidArgumentError(
                 "Could not connect to a Chroma server. Are you sure it is running?"
             )
         # Propagate ChromaErrors
         except ChromaError as e:
             raise e
         except Exception:
-            raise ValueError(
+            raise InvalidArgumentError(
                 f"Could not connect to tenant {tenant}. Are you sure it exists?"
             )
 
         try:
             self._admin_client.get_database(name=database, tenant=tenant)
         except httpx.ConnectError:
-            raise ValueError(
+            raise InvalidArgumentError(
                 "Could not connect to a Chroma server. Are you sure it is running?"
             )
 

chromadb/api/configuration.py

@@ -26,7 +26,7 @@ class StaticParameterError(Exception):
     pass
 
 
-class InvalidConfigurationError(ValueError):
+class InvalidConfigurationError(InvalidArgumentError):
     """Represents an error that occurs when a configuration is invalid."""
 
     pass
@@ -102,23 +102,23 @@ def __init__(self, parameters: Optional[List[ConfigurationParameter]] = None):
         if parameters is not None:
             for parameter in parameters:
                 if parameter.name not in self.definitions:
-                    raise ValueError(f"Invalid parameter name: {parameter.name}")
+                    raise InvalidArgumentError(f"Invalid parameter name: {parameter.name}")
 
                 definition = self.definitions[parameter.name]
                 # Handle the case where we have a recursive configuration definition
                 if isinstance(parameter.value, dict):
                     child_type = globals().get(parameter.value.get("_type", None))
                     if child_type is None:
-                        raise ValueError(
+                        raise InvalidArgumentError(
                             f"Invalid configuration type: {parameter.value}"
                         )
                     parameter.value = child_type.from_json(parameter.value)
                 if not isinstance(parameter.value, type(definition.default_value)):
-                    raise ValueError(f"Invalid parameter value: {parameter.value}")
+                    raise InvalidArgumentError(f"Invalid parameter value: {parameter.value}")
 
                 parameter_validator = definition.validator
                 if not parameter_validator(parameter.value):
-                    raise ValueError(f"Invalid parameter value: {parameter.value}")
+                    raise InvalidArgumentError(f"Invalid parameter value: {parameter.value}")
                 self.parameter_map[parameter.name] = parameter
         # Apply the defaults for any missing parameters
         for name, definition in self.definitions.items():
@@ -152,7 +152,7 @@ def get_parameters(self) -> List[ConfigurationParameter]:
     def get_parameter(self, name: str) -> ConfigurationParameter:
         """Returns the parameter with the given name, or except if it doesn't exist."""
         if name not in self.parameter_map:
-            raise ValueError(
+            raise InvalidArgumentError(
                 f"Invalid parameter name: {name} for configuration {self.__class__.__name__}"
             )
         param_value = cast(ConfigurationParameter, self.parameter_map.get(name))
@@ -161,13 +161,13 @@ def get_parameter(self, name: str) -> ConfigurationParameter:
     def set_parameter(self, name: str, value: Union[str, int, float, bool]) -> None:
         """Sets the parameter with the given name to the given value."""
         if name not in self.definitions:
-            raise ValueError(f"Invalid parameter name: {name}")
+            raise InvalidArgumentError(f"Invalid parameter name: {name}")
         definition = self.definitions[name]
         parameter = self.parameter_map[name]
         if definition.is_static:
             raise StaticParameterError(f"Cannot set static parameter: {name}")
         if not definition.validator(value):
-            raise ValueError(f"Invalid value for parameter {name}: {value}")
+            raise InvalidArgumentError(f"Invalid value for parameter {name}: {value}")
         parameter.value = value
 
     @override
@@ -182,7 +182,7 @@ def from_json_str(cls, json_str: str) -> Self:
         try:
             config_json = json.loads(json_str)
         except json.JSONDecodeError:
-            raise ValueError(
+            raise InvalidArgumentError(
                 f"Unable to decode configuration from JSON string: {json_str}"
             )
         return cls.from_json(config_json)
@@ -205,7 +205,7 @@ def to_json(self) -> Dict[str, Any]:
     def from_json(cls, json_map: Dict[str, Any]) -> Self:
         """Returns a configuration from the given JSON string."""
         if cls.__name__ != json_map.get("_type", None):
-            raise ValueError(
+            raise InvalidArgumentError(
                 f"Trying to instantiate configuration of type {cls.__name__} from JSON with type {json_map['_type']}"
             )
         parameters = []
@@ -308,7 +308,7 @@ def from_legacy_params(cls, params: Dict[str, Any]) -> Self:
         parameters = []
         for name, value in params.items():
             if name not in old_to_new:
-                raise ValueError(f"Invalid legacy HNSW parameter name: {name}")
+                raise InvalidArgumentError(f"Invalid legacy HNSW parameter name: {name}")
             parameters.append(
                 ConfigurationParameter(name=old_to_new[name], value=value)
             )

chromadb/api/models/AsyncCollection.py

@@ -53,11 +53,11 @@ async def add(
             None
 
         Raises:
-            ValueError: If you don't provide either embeddings or documents
-            ValueError: If the length of ids, embeddings, metadatas, or documents don't match
-            ValueError: If you don't provide an embedding function and don't provide embeddings
-            ValueError: If you provide both embeddings and documents
-            ValueError: If you provide an id that already exists
+            InvalidArgumentError: If you don't provide either embeddings or documents
+            InvalidArgumentError: If the length of ids, embeddings, metadatas, or documents don't match
+            InvalidArgumentError: If you don't provide an embedding function and don't provide embeddings
+            InvalidArgumentError: If you provide both embeddings and documents
+            InvalidArgumentError: If you provide an id that already exists
 
         """
         add_request = self._validate_and_prepare_add_request(
@@ -194,10 +194,10 @@ async def query(
             QueryResult: A QueryResult object containing the results.
 
         Raises:
-            ValueError: If you don't provide either query_embeddings, query_texts, or query_images
-            ValueError: If you provide both query_embeddings and query_texts
-            ValueError: If you provide both query_embeddings and query_images
-            ValueError: If you provide both query_texts and query_images
+            InvalidArgumentError: If you don't provide either query_embeddings, query_texts, or query_images
+            InvalidArgumentError: If you provide both query_embeddings and query_texts
+            InvalidArgumentError: If you provide both query_embeddings and query_images
+            InvalidArgumentError: If you provide both query_texts and query_images
 
         """
 
@@ -356,7 +356,7 @@ async def delete(
             None
 
         Raises:
-            ValueError: If you don't provide either ids, where, or where_document
+            InvalidArgumentError: If you don't provide either ids, where, or where_document
         """
         delete_request = self._validate_and_prepare_delete_request(
             ids, where, where_document

chromadb/api/models/Collection.py

@@ -71,11 +71,11 @@ def add(
             None
 
         Raises:
-            ValueError: If you don't provide either embeddings or documents
-            ValueError: If the length of ids, embeddings, metadatas, or documents don't match
-            ValueError: If you don't provide an embedding function and don't provide embeddings
-            ValueError: If you provide both embeddings and documents
-            ValueError: If you provide an id that already exists
+            InvalidArgumentError: If you don't provide either embeddings or documents
+            InvalidArgumentError: If the length of ids, embeddings, metadatas, or documents don't match
+            InvalidArgumentError: If you don't provide an embedding function and don't provide embeddings
+            InvalidArgumentError: If you provide both embeddings and documents
+            InvalidArgumentError: If you provide an id that already exists
 
         """
 
@@ -201,10 +201,10 @@ def query(
             QueryResult: A QueryResult object containing the results.
 
         Raises:
-            ValueError: If you don't provide either query_embeddings, query_texts, or query_images
-            ValueError: If you provide both query_embeddings and query_texts
-            ValueError: If you provide both query_embeddings and query_images
-            ValueError: If you provide both query_texts and query_images
+            InvalidArgumentError: If you don't provide either query_embeddings, query_texts, or query_images
+            InvalidArgumentError: If you provide both query_embeddings and query_texts
+            InvalidArgumentError: If you provide both query_embeddings and query_images
+            InvalidArgumentError: If you provide both query_texts and query_images
 
         """
 
@@ -369,7 +369,7 @@ def delete(
             None
 
         Raises:
-            ValueError: If you don't provide either ids, where, or where_document
+            InvalidArgumentError: If you don't provide either ids, where, or where_document
         """
         delete_request = self._validate_and_prepare_delete_request(
             ids, where, where_document

chromadb/api/models/CollectionCommon.py

@@ -242,7 +242,7 @@ def _validate_and_prepare_get_request(
         validate_include(include=include, dissalowed=[IncludeEnum.distances])
 
         if IncludeEnum.data in include and self._data_loader is None:
-            raise ValueError(
+            raise InvalidArgumentError(
                 "You must set a data loader on the collection if loading from URIs."
             )
 
@@ -423,7 +423,7 @@ def _validate_and_prepare_delete_request(
         where_document: Optional[WhereDocument],
     ) -> DeleteRequest:
         if ids is None and where is None and where_document is None:
-            raise ValueError(
+            raise InvalidArgumentError(
                 "At least one of ids, where, or where_document must be provided"
             )
 
@@ -493,7 +493,7 @@ def _validate_modify_request(self, metadata: Optional[CollectionMetadata]) -> No
         if metadata is not None:
             validate_metadata(metadata)
             if "hnsw:space" in metadata:
-                raise ValueError(
+                raise InvalidArgumentError(
                     "Changing the distance function of a collection once it is created is not supported currently."
                 )
 
@@ -516,23 +516,23 @@ def _embed_record_set(
                 # uris require special handling
                 if field == "uris":
                     if self._data_loader is None:
-                        raise ValueError(
+                        raise InvalidArgumentError(
                             "You must set a data loader on the collection if loading from URIs."
                         )
                     return self._embed(
                         input=self._data_loader(uris=cast(URIs, record_set[field]))  # type: ignore[literal-required]
                     )
                 else:
                     return self._embed(input=record_set[field])  # type: ignore[literal-required]
-        raise ValueError(
+        raise InvalidArgumentError(
             "Record does not contain any non-None fields that can be embedded."
             f"Embeddable Fields: {embeddable_fields}"
             f"Record Fields: {record_set}"
         )
 
     def _embed(self, input: Any) -> Embeddings:
         if self._embedding_function is None:
-            raise ValueError(
+            raise InvalidArgumentError(
                 "You must provide an embedding function to compute embeddings."
                 "https://docs.trychroma.com/guides/embeddings"
             )