hiderfong/prop-data-guard
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fix(celery): 修复AsyncResult缺少celery_app导致DisabledBackend错误

Browse Source 
- project.py中AsyncResult调用添加app=celery_app参数
- 解决自动分类状态查询时500错误
This commit is contained in:
hiderfong
2026-04-26 08:45:46 +08:00
parent ad2f49de11
commit 1c5dfb12e1
1 changed files with 4 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files
backend/app/api/v1/project.py
+4 -2
View File
@@ -115,7 +115,8 @@ def project_auto_classify(
if background: if background:
# Check if already running # Check if already running
if project.celery_task_id: if project.celery_task_id:
existing = AsyncResult(project.celery_task_id) from app.tasks.worker import celery_app
existing = AsyncResult(project.celery_task_id, app=celery_app)
if existing.state in ("PENDING", "PROGRESS", "STARTED"): if existing.state in ("PENDING", "PROGRESS", "STARTED"):
return ResponseModel(data={"task_id": project.celery_task_id, "status": existing.state}) return ResponseModel(data={"task_id": project.celery_task_id, "status": existing.state})
@@ -163,7 +164,8 @@ def project_auto_classify_status(
progress = json.loads(project.scan_progress) if project.scan_progress else None progress = json.loads(project.scan_progress) if project.scan_progress else None
return ResponseModel(data={"status": project.status, "progress": progress}) return ResponseModel(data={"status": project.status, "progress": progress})
result = AsyncResult(task_id) from app.tasks.worker import celery_app
result = AsyncResult(task_id, app=celery_app)
progress = None progress = None
if result.state == "PROGRESS" and result.info: if result.state == "PROGRESS" and result.info:
progress = result.info progress = result.info