yumoqing/longtasks
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

bugfix

Browse Source
This commit is contained in:
yumoqing 2025-11-06 14:47:54 +08:00
parent e714d217e2
commit 580029955e
1 changed files with 5 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
longtasks/longtasks.py
View File

@ -220,15 +220,15 @@ class LongTasks:
async def get_redis_task(self, taskid):
task = await self.redis.hgetall(f'{self.taskname}:task:{taskid}')
if task['created_at']:
if task.get('created_at'):
task['created_at'] = float(task['created_at'])
if task['started_at']:
if task.get('started_at'):
task['started_at'] = float(task['started_at'])
if task['finished_at']:
if task.get('finished_at'):
task['finished_at'] = float(task['finished_at'])
if task['payload']:
if task.get('payload'):
task['payload'] = json.loads(task['payload'])
if task['status'] == 'SUCCEEDED' and task['result']:
if task.get('status') == 'SUCCEEDED' and task.get('result'):
task['result'] = json.loads(task['result'])
return task