fix(knowledge): mark connector errored and document failed when KB is deleted

Author: waleedlatif1

apps/sim/lib/knowledge/connectors/sync-engine.ts

@@ -305,6 +305,15 @@ export async function executeSync(
     logger.warn(
       `Skipping sync: knowledge base ${connector.knowledgeBaseId} is deleted (connector ${connectorId})`
     )
+    await db
+      .update(knowledgeConnector)
+      .set({
+        status: 'error',
+        nextSyncAt: null,
+        lastSyncError: 'Knowledge base deleted',
+        updatedAt: new Date(),
+      })
+      .where(eq(knowledgeConnector.id, connectorId))
     return { ...result, error: 'knowledge_base_deleted' }
   }
 

apps/sim/lib/knowledge/documents/service.ts

@@ -389,6 +389,16 @@ export async function processDocumentAsync(
       logger.warn(
         `[${documentId}] Skipping document processing: knowledge base ${knowledgeBaseId} is deleted`
       )
+      await db
+        .update(document)
+        .set({
+          processingStatus: 'failed',
+          processingError: 'Knowledge base deleted',
+          processingCompletedAt: new Date(),
+        })
+        .where(
+          and(eq(document.id, documentId), isNull(document.archivedAt), isNull(document.deletedAt))
+        )
       return
     }