bug fix in embedding deletion (#889)

Author: kaushal1999

backend/python/app/modules/indexing/run.py

@@ -666,7 +666,6 @@ async def delete_embeddings(self, record_id: str, virtual_record_id: str) -> Non
 
                 ids = [point.id for point in result[0]] #type: ignore
                 self.logger.info(f"🎯 Filter: {filter_dict}")
-                self.logger.info(f"🎯 Ids: {ids}")
 
                 try:
                     await self.get_embedding_model_instance()

backend/python/app/services/messaging/kafka/handlers/record.py

@@ -132,12 +132,7 @@ async def process_event(self, event_type: str, payload: dict) -> bool:
             record = await self.event_processor.arango_service.get_document(
                 record_id, CollectionNames.RECORDS.value
             )
-            if record is None:
-                self.logger.error(f"❌ Record {record_id} not found in database")
-                return False
 
-            if virtual_record_id is None:
-                virtual_record_id = record.get("virtualRecordId")
 
             self.logger.info(
                 f"Processing record {record_id} with event type: {event_type}. "
@@ -155,6 +150,13 @@ async def process_event(self, event_type: str, payload: dict) -> bool:
                 # self.logger.info(f"Scheduled update for record {record_id}")
                 await self.event_processor.processor.indexing_pipeline.delete_embeddings(record_id, virtual_record_id)
 
+            if record is None:
+                self.logger.error(f"❌ Record {record_id} not found in database")
+                return False
+
+            if virtual_record_id is None:
+                virtual_record_id = record.get("virtualRecordId")
+
 
             if extension is None and mime_type != "text/gmail_content":
                 extension = payload.get("extension", None)