[NOTICKET][document] delete from vector embedding if user delete document in knowledge

src/document/document_service.py

@@ -1,7 +1,7 @@
 """Service for managing documents."""
 
 from sqlalchemy.ext.asyncio import AsyncSession
-from sqlalchemy import select, delete
+from sqlalchemy import select, delete, text
 from src.db.postgres.models import Document
 from src.storage.az_blob.az_blob import blob_storage
 from src.middlewares.logging import get_logger
@@ -77,6 +77,12 @@ class DocumentService:
         # Delete from blob storage
         await blob_storage.delete_file(document.blob_name)
 
+        # Delete vector embeddings from pgvector
+        await db.execute(
+            text("DELETE FROM langchain_pg_embedding WHERE cmetadata->'data'->>'document_id' = :doc_id"),
+            {"doc_id": document_id}
+        )
+
         # Delete from database
         await db.execute(
             delete(Document).where(Document.id == document_id)