yangdx
commited on
Commit
·
2e31f26
1
Parent(s):
b012523
Improved logging clarity in storage operations
Browse files
lightrag/kg/json_doc_status_impl.py
CHANGED
|
@@ -107,7 +107,7 @@ class JsonDocStatusStorage(DocStatusStorage):
|
|
| 107 |
async def upsert(self, data: dict[str, dict[str, Any]]) -> None:
|
| 108 |
if not data:
|
| 109 |
return
|
| 110 |
-
logger.info(f"Inserting {len(data)} to {self.namespace}")
|
| 111 |
async with self._storage_lock:
|
| 112 |
self._data.update(data)
|
| 113 |
await set_all_update_flags(self.namespace)
|
|
|
|
| 107 |
async def upsert(self, data: dict[str, dict[str, Any]]) -> None:
|
| 108 |
if not data:
|
| 109 |
return
|
| 110 |
+
logger.info(f"Inserting {len(data)} records to {self.namespace}")
|
| 111 |
async with self._storage_lock:
|
| 112 |
self._data.update(data)
|
| 113 |
await set_all_update_flags(self.namespace)
|
lightrag/kg/json_kv_impl.py
CHANGED
|
@@ -108,7 +108,7 @@ class JsonKVStorage(BaseKVStorage):
|
|
| 108 |
async def upsert(self, data: dict[str, dict[str, Any]]) -> None:
|
| 109 |
if not data:
|
| 110 |
return
|
| 111 |
-
logger.info(f"Inserting {len(data)} to {self.namespace}")
|
| 112 |
async with self._storage_lock:
|
| 113 |
self._data.update(data)
|
| 114 |
await set_all_update_flags(self.namespace)
|
|
|
|
| 108 |
async def upsert(self, data: dict[str, dict[str, Any]]) -> None:
|
| 109 |
if not data:
|
| 110 |
return
|
| 111 |
+
logger.info(f"Inserting {len(data)} records to {self.namespace}")
|
| 112 |
async with self._storage_lock:
|
| 113 |
self._data.update(data)
|
| 114 |
await set_all_update_flags(self.namespace)
|