diff --git a/lightrag/kg/json_doc_status_impl.py b/lightrag/kg/json_doc_status_impl.py index 3c1fb4c2..5b378c17 100644 --- a/lightrag/kg/json_doc_status_impl.py +++ b/lightrag/kg/json_doc_status_impl.py @@ -107,7 +107,7 @@ class JsonDocStatusStorage(DocStatusStorage): async def upsert(self, data: dict[str, dict[str, Any]]) -> None: if not data: return - logger.info(f"Inserting {len(data)} to {self.namespace}") + logger.info(f"Inserting {len(data)} records to {self.namespace}") async with self._storage_lock: self._data.update(data) await set_all_update_flags(self.namespace) diff --git a/lightrag/kg/json_kv_impl.py b/lightrag/kg/json_kv_impl.py index b5d963fb..6c855a25 100644 --- a/lightrag/kg/json_kv_impl.py +++ b/lightrag/kg/json_kv_impl.py @@ -108,7 +108,7 @@ class JsonKVStorage(BaseKVStorage): async def upsert(self, data: dict[str, dict[str, Any]]) -> None: if not data: return - logger.info(f"Inserting {len(data)} to {self.namespace}") + logger.info(f"Inserting {len(data)} records to {self.namespace}") async with self._storage_lock: self._data.update(data) await set_all_update_flags(self.namespace)