From 45d38fa0833d4dd70200daab70d44fda7bf4b7f3 Mon Sep 17 00:00:00 2001 From: yangdx Date: Wed, 16 Jul 2025 01:35:07 +0800 Subject: [PATCH] Fix JSON error logging in Redis storage implementations --- lightrag/kg/redis_impl.py | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/lightrag/kg/redis_impl.py b/lightrag/kg/redis_impl.py index 17b0d4fb..0ac0cb44 100644 --- a/lightrag/kg/redis_impl.py +++ b/lightrag/kg/redis_impl.py @@ -349,8 +349,8 @@ class RedisKVStorage(BaseKVStorage): pipe.set(f"{self.namespace}:{k}", json.dumps(v)) await pipe.execute() - except json.JSONEncodeError as e: - logger.error(f"JSON encode error during upsert: {e}") + except json.JSONDecodeError as e: + logger.error(f"JSON decode error during upsert: {e}") raise async def index_done_callback(self) -> None: @@ -807,8 +807,8 @@ class RedisDocStatusStorage(DocStatusStorage): for k, v in data.items(): pipe.set(f"{self.namespace}:{k}", json.dumps(v)) await pipe.execute() - except json.JSONEncodeError as e: - logger.error(f"JSON encode error during upsert: {e}") + except json.JSONDecodeError as e: + logger.error(f"JSON decode error during upsert: {e}") raise async def get_by_id(self, id: str) -> Union[dict[str, Any], None]: