From c3253584fd23c7b4ffee382ca5cca233c6ea284c Mon Sep 17 00:00:00 2001 From: yumoqing Date: Thu, 6 Nov 2025 14:25:14 +0800 Subject: [PATCH] bugfix --- longtasks/longtasks.py | 12 ++++++++++++ 1 file changed, 12 insertions(+) diff --git a/longtasks/longtasks.py b/longtasks/longtasks.py index ef8d557..c644340 100644 --- a/longtasks/longtasks.py +++ b/longtasks/longtasks.py @@ -7,6 +7,7 @@ import json import time from typing import Any, Dict from appPublic.worker import get_event_loop, schedule_interval, schedule_once +from appPublic.dictObject import DictObject from appPublic.uniqueID import getID from appPublic.log import debug, exception @@ -219,6 +220,17 @@ class LongTasks: async def get_redis_task(self, taskid): task = await self.redis.hgetall(f'{self.taskname}:task:{taskid}') + task = DictObject(**task) + if task.created_at: + task.created_at = float(task.created_at) + if task.started_at: + task.started_at = float(task.started_at) + if task.finished_at: + task.finished_at = float(task.finished_at) + if task.payload: + task.payload = json.loads(taskload) + if task.status == 'SUCCEEDED' and task.result: + task.result = json.loads(task.result) return task async def delete_redis_task(self, taskid):