diff --git a/llama_index/embeddings/base.py b/llama_index/embeddings/base.py index c2dc8b0bce3064348fcda0a0133f4e566e4b13d4..3aafb268616c9a3cf72fb646ecf67fad92943257 100644 --- a/llama_index/embeddings/base.py +++ b/llama_index/embeddings/base.py @@ -258,6 +258,7 @@ class BaseEmbedding(BaseComponent): ) callback_payloads.append((event_id, cur_batch)) embeddings_coroutines.append(self._aget_text_embeddings(cur_batch)) + cur_batch = [] # flatten the results of asyncio.gather, which is a list of embeddings lists nested_embeddings = []