From 6a4f1b218823dc39c9cef95e5db5b76eee866419 Mon Sep 17 00:00:00 2001 From: Debanjum Singh Solanky Date: Tue, 17 Oct 2023 05:31:57 -0700 Subject: [PATCH] Add more client, request details in logs by index/update API endpoint --- src/khoj/routers/indexer.py | 10 ++++++---- 1 file changed, 6 insertions(+), 4 deletions(-) diff --git a/src/khoj/routers/indexer.py b/src/khoj/routers/indexer.py index 321b3788..a09e33f5 100644 --- a/src/khoj/routers/indexer.py +++ b/src/khoj/routers/indexer.py @@ -72,7 +72,7 @@ async def update( raise HTTPException(status_code=401, detail="Invalid API Key") state.config_lock.acquire() try: - logger.info("📬 Updating content index via API") + logger.info(f"📬 Updating content index via API call by {client}") org_files: Dict[str, str] = {} markdown_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() ) 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( org=org_files, @@ -138,7 +138,9 @@ async def update( ) 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: state.config_lock.release() @@ -152,7 +154,7 @@ async def update( 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)