Quellcode durchsuchen

imprv deleteObsoleteVectorStoreFile()

Shun Miyazawa vor 1 Jahr
Ursprung
Commit
02591e87d1
1 geänderte Dateien mit 5 neuen und 1 gelöschten Zeilen
  1. 5 1
      apps/app/src/features/openai/server/services/openai.ts

+ 5 - 1
apps/app/src/features/openai/server/services/openai.ts

@@ -280,10 +280,14 @@ class OpenaiService implements IOpenaiService {
       return;
       return;
     }
     }
 
 
-    const obsoleteVectorStoreFiles = VectorStoreFileRelationModel.find(
+    const obsoleteVectorStoreFiles = await VectorStoreFileRelationModel.find(
       { vectorStoreRelationId: { $in: deletedVectorStores.map(vectorStore => vectorStore._id) } },
       { vectorStoreRelationId: { $in: deletedVectorStores.map(vectorStore => vectorStore._id) } },
     ).limit(limit);
     ).limit(limit);
 
 
+    if (obsoleteVectorStoreFiles == null) {
+      return;
+    }
+
     for await (const vectorStoreFile of obsoleteVectorStoreFiles) {
     for await (const vectorStoreFile of obsoleteVectorStoreFiles) {
       try {
       try {
         await this.deleteVectorStoreFile(vectorStoreFile.vectorStoreRelationId, vectorStoreFile.pageId, apiCallInterval);
         await this.deleteVectorStoreFile(vectorStoreFile.vectorStoreRelationId, vectorStoreFile.pageId, apiCallInterval);