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

Reduce log level of noisy process lock logs

Browse Source
This commit is contained in:
Debanjum Singh Solanky
2024-05-29 13:14:44 +05:30
parent 7b18919564
commit 215db8cab3
1 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
src/khoj/database/adapters/__init__.py
View File

@@ -447,7 +447,7 @@ class ProcessLockAdapters:
def run_with_lock(func: Callable, operation: ProcessLock.Operation, max_duration_in_seconds: int = 600, **kwargs): def run_with_lock(func: Callable, operation: ProcessLock.Operation, max_duration_in_seconds: int = 600, **kwargs):
# Exit early if process lock is already taken # Exit early if process lock is already taken
if ProcessLockAdapters.is_process_locked(operation): if ProcessLockAdapters.is_process_locked(operation):
logger.info(f"🔒 Skip executing {func} as {operation} lock is already taken") logger.debug(f"🔒 Skip executing {func} as {operation} lock is already taken")
return return
success = False success = False
@@ -462,7 +462,7 @@ class ProcessLockAdapters:
func(**kwargs) func(**kwargs)
success = True success = True
except IntegrityError as e: except IntegrityError as e:
logger.error(f"⚠️ Unable to create the process lock for {func} with {operation}: {e}") logger.debug(f"⚠️ Unable to create the process lock for {func} with {operation}: {e}")
success = False success = False
except Exception as e: except Exception as e:
logger.error(f"🚨 Error executing {func} with {operation} process lock: {e}", exc_info=True) logger.error(f"🚨 Error executing {func} with {operation} process lock: {e}", exc_info=True)
@@ -475,7 +475,7 @@ class ProcessLockAdapters:
f"🔓 Unlocked {operation} process after executing {func} {'Succeeded' if success else 'Failed'}" f"🔓 Unlocked {operation} process after executing {func} {'Succeeded' if success else 'Failed'}"
) )
else: else:
logger.info(f"Skip removing {operation} process lock as it was not set") logger.debug(f"Skip removing {operation} process lock as it was not set")
def run_with_process_lock(*args, **kwargs): def run_with_process_lock(*args, **kwargs):