klbr/khoj
1
0
Fork 0
mirror of https://github.com/khoaliber/khoj.git synced 2026-03-08 05:39:13 +00:00
Code Issues Packages Projects Releases Wiki Activity

Add more client, request details in logs by index/update API endpoint

Browse Source
This commit is contained in:
Debanjum Singh Solanky
2023-10-17 05:31:57 -07:00
parent 5efae1ad55
commit 6a4f1b2188
1 changed files with 6 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
src/khoj/routers/indexer.py
View File

@@ -72,7 +72,7 @@ async def update(
raise HTTPException(status_code=401, detail="Invalid API Key") raise HTTPException(status_code=401, detail="Invalid API Key")
state.config_lock.acquire() state.config_lock.acquire()
try: try:
logger.info("📬 Updating content index via API") logger.info(f"📬 Updating content index via API call by {client}")
org_files: Dict[str, str] = {} org_files: Dict[str, str] = {}
markdown_files: Dict[str, str] = {} markdown_files: Dict[str, str] = {}
pdf_files: Dict[str, str] = {} pdf_files: Dict[str, str] = {}
@@ -95,7 +95,7 @@ async def update(
file.file.read().decode("utf-8") if encoding == "utf-8" else file.file.read() file.file.read().decode("utf-8") if encoding == "utf-8" else file.file.read()
) )
else: else:
logger.warning(f"Skipped indexing unsupported file type sent by client: {file.filename}") logger.warning(f"Skipped indexing unsupported file type sent by {client} client: {file.filename}")
indexer_input = IndexerInput( indexer_input = IndexerInput(
org=org_files, org=org_files,
@@ -138,7 +138,9 @@ async def update(
) )
except Exception as e: except Exception as e:
logger.error(f"🚨 Failed to update content index via API: {e}", exc_info=True) logger.error(
f"🚨 Failed to {force} update {t} content index triggered via API call by {client}: {e}", exc_info=True
)
finally: finally:
state.config_lock.release() state.config_lock.release()
@@ -152,7 +154,7 @@ async def update(
host=host, host=host,
) )
logger.info("📪 Content index updated via API") logger.info(f"📪 Content index updated via API call by {client}")
return Response(content="OK", status_code=200) return Response(content="OK", status_code=200)