From 580029955e6fe2917fb84b5005a712d820e0e42b Mon Sep 17 00:00:00 2001 From: yumoqing Date: Thu, 6 Nov 2025 14:47:54 +0800 Subject: [PATCH] bugfix --- longtasks/longtasks.py | 10 +++++----- 1 file changed, 5 insertions(+), 5 deletions(-) diff --git a/longtasks/longtasks.py b/longtasks/longtasks.py index 8537152..4c0a8b7 100644 --- a/longtasks/longtasks.py +++ b/longtasks/longtasks.py @@ -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