From 0a4f076a0bd3d0282767edd74a8cc8e265f6920a Mon Sep 17 00:00:00 2001
From: yumoqing <yumoqing@gmail.com>
Date: Thu, 6 Nov 2025 11:48:11 +0800
Subject: [PATCH] bugfix

---
 longtasks/longtasks.py | 2 ++
 1 file changed, 2 insertions(+)

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()