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