diff --git a/lightrag/kg/shared_storage.py b/lightrag/kg/shared_storage.py index 10e83e56..b5d56f5d 100644 --- a/lightrag/kg/shared_storage.py +++ b/lightrag/kg/shared_storage.py @@ -122,16 +122,20 @@ class UnifiedLock(Generic[T]): self._lock.release() else: self._lock.release() - 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 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() + direct_log( + f"== Lock == Process {self._pid}: Async lock '{self._name}' released", + enable_output=self._enable_logging, + ) direct_log( f"== Lock == Process {self._pid}: Lock '{self._name}' released (async={self._is_async})",