mirror of
https://github.com/basicmachines-co/basic-memory
synced 2026-06-21 13:47:35 +00:00
add info logging to index_entity_data background task
Signed-off-by: phernandez <paul@basicmachines.co>
This commit is contained in:
@@ -184,13 +184,29 @@ class SearchService:
|
||||
entity: Entity,
|
||||
content: str | None = None,
|
||||
) -> None:
|
||||
# delete all search index data associated with entity
|
||||
await self.repository.delete_by_entity_id(entity_id=entity.id)
|
||||
logger.info(
|
||||
f"[BackgroundTask] Starting search index for entity_id={entity.id} "
|
||||
f"permalink={entity.permalink} project_id={entity.project_id}"
|
||||
)
|
||||
try:
|
||||
# delete all search index data associated with entity
|
||||
await self.repository.delete_by_entity_id(entity_id=entity.id)
|
||||
|
||||
# reindex
|
||||
await self.index_entity_markdown(
|
||||
entity, content
|
||||
) if entity.is_markdown else await self.index_entity_file(entity)
|
||||
# reindex
|
||||
await self.index_entity_markdown(
|
||||
entity, content
|
||||
) if entity.is_markdown else await self.index_entity_file(entity)
|
||||
|
||||
logger.info(
|
||||
f"[BackgroundTask] Completed search index for entity_id={entity.id} "
|
||||
f"permalink={entity.permalink}"
|
||||
)
|
||||
except Exception as e:
|
||||
logger.error(
|
||||
f"[BackgroundTask] Failed search index for entity_id={entity.id} "
|
||||
f"permalink={entity.permalink} error={e}"
|
||||
)
|
||||
raise
|
||||
|
||||
async def index_entity_file(
|
||||
self,
|
||||
|
||||
Reference in New Issue
Block a user