Skip to content

Commit 5b3b631

Browse files
committed
Avoid retrying errors for invalid Vertex AI embedding requests
1 parent f6795ce commit 5b3b631

File tree

1 file changed

+5
-0
lines changed

1 file changed

+5
-0
lines changed

redisvl/utils/vectorize/vertexai.py

Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -2,6 +2,7 @@
22
from functools import cached_property
33
from typing import TYPE_CHECKING, Any, Dict, List, Optional, Union
44

5+
from google.api_core.exceptions import InvalidArgument
56
from pydantic import ConfigDict
67
from tenacity import retry, stop_after_attempt, wait_random_exponential
78
from tenacity.retry import retry_if_not_exception_type
@@ -282,6 +283,8 @@ def _embed(self, content: Any, **kwargs) -> List[float]:
282283
else:
283284
return self._client.get_embeddings([content], **kwargs)[0].values
284285

286+
except InvalidArgument as e:
287+
raise TypeError(f"Invalid input for embedding: {str(e)}") from e
285288
except Exception as e:
286289
raise ValueError(f"Embedding input failed: {e}")
287290

@@ -323,6 +326,8 @@ def _embed_many(
323326
response = self._client.get_embeddings(batch, **kwargs)
324327
embeddings.extend([r.values for r in response])
325328
return embeddings
329+
except InvalidArgument as e:
330+
raise TypeError(f"Invalid input for embedding: {str(e)}") from e
326331
except Exception as e:
327332
raise ValueError(f"Embedding texts failed: {e}")
328333

0 commit comments

Comments
 (0)