jim/morphik-core
1
0
Fork 0
mirror of https://github.com/james-m-jordan/morphik-core.git synced 2025-05-09 19:32:38 +00:00
Code Issues Packages Projects Releases Wiki Activity

Mark ingest_text as complete when ingestion finished

Browse Source
This commit is contained in:
Adityavardhan Agrawal 2025-04-21 00:33:25 -07:00
parent 4b9869baf7
commit 1c79a62fb2
1 changed files with 9 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
core/services/document_service.py
View File

@ -636,6 +636,15 @@ class DocumentService:
await self._store_chunks_and_doc(chunk_objects, doc, use_colpali, chunk_objects_multivector) await self._store_chunks_and_doc(chunk_objects, doc, use_colpali, chunk_objects_multivector)
logger.debug(f"Successfully stored text document {doc.external_id}") logger.debug(f"Successfully stored text document {doc.external_id}")
# Update the document status to completed after successful storage
# This matches the behavior in ingestion_worker.py
doc.system_metadata["status"] = "completed"
doc.system_metadata["updated_at"] = datetime.now(UTC)
await self.db.update_document(
document_id=doc.external_id, updates={"system_metadata": doc.system_metadata}, auth=auth
)
logger.debug(f"Updated document status to 'completed' for {doc.external_id}")
return doc return doc
# TODO: check if it's unused. if so, remove it. # TODO: check if it's unused. if so, remove it.