diff --git a/api/src/services/embedding.js b/api/src/services/embedding.js
index 3d4fea17..5fea8386 100644
--- a/api/src/services/embedding.js
+++ b/api/src/services/embedding.js
@@ -361,7 +361,7 @@ export class EmbeddingService {
           return JSON.stringify(itemStream.stream_content);
         }));
 
-        await collection.add({
+        await collection.upsert({
           ids: newIds,
           embeddings: newVectors,  // Use existing vectors
           metadatas: newMetadatas,