gardel/lightrag
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Optimize log messages

Browse Source
This commit is contained in:
yangdx
2025-04-29 13:32:05 +08:00
parent c153aa697c
commit 5f3e210246
1 changed files with 9 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

14
lightrag/kg/shared_storage.py
View File

@@ -122,16 +122,20 @@ class UnifiedLock(Generic[T]):
self._lock.release() self._lock.release()
else: else:
self._lock.release() self._lock.release()
main_lock_released = True main_lock_released = True
direct_log(
f"== Lock == Process {self._pid}: Lock '{self._name}' released (async={self._is_async})",
enable_output=self._enable_logging,
)
# Then release async lock if in multiprocess mode # Then release async lock if in multiprocess mode
if not self._is_async and self._async_lock is not None: if not self._is_async and self._async_lock is not None:
# direct_log(
# f"== Lock == Process {self._pid}: Releasing async lock for '{self._name}'",
# enable_output=self._enable_logging,
# )
self._async_lock.release() self._async_lock.release()
direct_log(
f"== Lock == Process {self._pid}: Async lock '{self._name}' released",
enable_output=self._enable_logging,
)
direct_log( direct_log(
f"== Lock == Process {self._pid}: Lock '{self._name}' released (async={self._is_async})", f"== Lock == Process {self._pid}: Lock '{self._name}' released (async={self._is_async})",