diff --git a/longtasks/longtasks.py b/longtasks/longtasks.py
index ba6b7ae..ef8d557 100644
--- a/longtasks/longtasks.py
+++ b/longtasks/longtasks.py
@@ -144,6 +144,8 @@ class LongTasks:
 
 				task_obj = await self.get_redis_task(task_id)
 				payload = task_obj["payload"]
+				debug(f'task={task_obj}')
+				payload = json.loads(payload)
 
 				# 1) 更新 task hash 为 running（这一步很重要：客户端读取到状态）
 				started_at = time.time()