From 4bace9517d4fa77f1978cde38e0e5ba5c3a1ff4f Mon Sep 17 00:00:00 2001
From: yanta <hai.yang@sayweee.com>
Date: Wed, 18 Sep 2024 11:31:56 +0800
Subject: [PATCH] =?UTF-8?q?celery=20=E6=9F=A5=E7=9C=8B=E5=BC=82=E6=AD=A5?=
 =?UTF-8?q?=E4=BB=BB=E5=8A=A1=E8=AF=A6=E6=83=85?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 sql/utils/tasks.py | 14 ++++++++------
 1 file changed, 8 insertions(+), 6 deletions(-)

diff --git a/sql/utils/tasks.py b/sql/utils/tasks.py
index 15de20f7fb..e866cf9a55 100644
--- a/sql/utils/tasks.py
+++ b/sql/utils/tasks.py
@@ -3,6 +3,7 @@
 from celery import signature
 from celery.result import AsyncResult
 from celery.exceptions import SoftTimeLimitExceeded
+from django.http import JsonResponse
 import logging
 import pytz
 
@@ -56,11 +57,12 @@ def del_schedule(name):
     except Exception as e:
         print(f"终止任务时发生错误：{str(e)}")
 
-
 def task_info(name):
     """获取定时任务详情"""
-    try:
-        periodic_task = PeriodicTask.objects.get(name=name)
-        return periodic_task
-    except PeriodicTask.DoesNotExist:
-        return None
\ No newline at end of file
+    task_result = AsyncResult(name)
+    response = {
+        'task_id': name,
+        'status': task_result.state,
+        'result': task_result.result
+    }
+    return JsonResponse(response)