diff --git a/video-gen-api/app/admin_api/scheduled_tasks/routes.py b/video-gen-api/app/admin_api/scheduled_tasks/routes.py index d10cb1a7..5baed0e3 100644 --- a/video-gen-api/app/admin_api/scheduled_tasks/routes.py +++ b/video-gen-api/app/admin_api/scheduled_tasks/routes.py @@ -148,9 +148,10 @@ async def run_task( if task is None: raise HTTPException(status_code=404, detail="任务不存在") + from app.tasks.celery_app import RECOVERY_QUEUE from app.tasks.scheduled_tasks import execute_scheduled_task - execute_scheduled_task.apply_async(args=[task_id]) + execute_scheduled_task.apply_async(args=[task_id], queue=RECOVERY_QUEUE) return {"message": "任务已提交执行"}