diff --git a/langchain/embeddings/openai.py b/langchain/embeddings/openai.py index fbf6a1bcff4..3b8fa5559fd 100644 --- a/langchain/embeddings/openai.py +++ b/langchain/embeddings/openai.py @@ -147,11 +147,13 @@ class OpenAIEmbeddings(BaseModel, Embeddings): texts, engine=self.document_model_name, chunk_size=chunk_size ) else: - responses = [ - self._embedding_func(text, engine=self.document_model_name) - for text in texts - ] - return responses + results = [] + for i in range(0, len(texts), chunk_size): + response = self.client.create( + input=texts[i : i + chunk_size], engine=self.document_model_name + ) + results += [r["embedding"] for r in response["data"]] + return results def embed_query(self, text: str) -> List[float]: """Call out to OpenAI's embedding endpoint for embedding query text.