diff --git a/longtasks/longtasks.py b/longtasks/longtasks.py index 4c0a8b7..d017512 100644 --- a/longtasks/longtasks.py +++ b/longtasks/longtasks.py @@ -146,7 +146,6 @@ 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()