bugfix
This commit is contained in:
parent
580029955e
commit
3497f30c96
@ -146,7 +146,6 @@ class LongTasks:
|
|||||||
task_obj = await self.get_redis_task(task_id)
|
task_obj = await self.get_redis_task(task_id)
|
||||||
payload = task_obj["payload"]
|
payload = task_obj["payload"]
|
||||||
debug(f'task={task_obj}')
|
debug(f'task={task_obj}')
|
||||||
payload = json.loads(payload)
|
|
||||||
|
|
||||||
# 1) 更新 task hash 为 running(这一步很重要:客户端读取到状态)
|
# 1) 更新 task hash 为 running(这一步很重要:客户端读取到状态)
|
||||||
started_at = time.time()
|
started_at = time.time()
|
||||||
|
|||||||
Loading…
x
Reference in New Issue
Block a user