yangdx
commited on
Commit
·
cf070f3
1
Parent(s):
e9b482a
Optimize log messages
Browse files
lightrag/kg/shared_storage.py
CHANGED
|
@@ -112,11 +112,6 @@ class UnifiedLock(Generic[T]):
|
|
| 112 |
async def __aexit__(self, exc_type, exc_val, exc_tb):
|
| 113 |
main_lock_released = False
|
| 114 |
try:
|
| 115 |
-
# direct_log(
|
| 116 |
-
# f"== Lock == Process {self._pid}: Releasing lock '{self._name}' (async={self._is_async})",
|
| 117 |
-
# enable_output=self._enable_logging,
|
| 118 |
-
# )
|
| 119 |
-
|
| 120 |
# Release main lock first
|
| 121 |
if self._is_async:
|
| 122 |
self._lock.release()
|
|
@@ -137,10 +132,6 @@ class UnifiedLock(Generic[T]):
|
|
| 137 |
enable_output=self._enable_logging,
|
| 138 |
)
|
| 139 |
|
| 140 |
-
direct_log(
|
| 141 |
-
f"== Lock == Process {self._pid}: Lock '{self._name}' released (async={self._is_async})",
|
| 142 |
-
enable_output=self._enable_logging,
|
| 143 |
-
)
|
| 144 |
except Exception as e:
|
| 145 |
direct_log(
|
| 146 |
f"== Lock == Process {self._pid}: Failed to release lock '{self._name}': {e}",
|
|
|
|
| 112 |
async def __aexit__(self, exc_type, exc_val, exc_tb):
|
| 113 |
main_lock_released = False
|
| 114 |
try:
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
| 115 |
# Release main lock first
|
| 116 |
if self._is_async:
|
| 117 |
self._lock.release()
|
|
|
|
| 132 |
enable_output=self._enable_logging,
|
| 133 |
)
|
| 134 |
|
|
|
|
|
|
|
|
|
|
|
|
|
| 135 |
except Exception as e:
|
| 136 |
direct_log(
|
| 137 |
f"== Lock == Process {self._pid}: Failed to release lock '{self._name}': {e}",
|