diff --git a/lightrag/kg/json_kv_impl.py b/lightrag/kg/json_kv_impl.py index 62f7289d..2d44ce00 100644 --- a/lightrag/kg/json_kv_impl.py +++ b/lightrag/kg/json_kv_impl.py @@ -197,3 +197,10 @@ class JsonKVStorage(BaseKVStorage): except Exception as e: logger.error(f"Error dropping {self.namespace}: {e}") return {"status": "error", "message": str(e)} + + async def finalize(self): + """Finalize storage resources + Persistence cache data to disk before exiting + """ + if self.namespace.endswith("cache"): + await self.index_done_callback()