diff --git a/flask_app/celery_app.py b/flask_app/celery_app.py index 7010ab0..92fa220 100644 --- a/flask_app/celery_app.py +++ b/flask_app/celery_app.py @@ -11,7 +11,7 @@ celery_app = Celery( # 设置任务队列的速率限制(全局每分钟 250 次) celery_app.conf.task_annotations = { - 'tasks.process_qianwen_long': {'rate_limit': '250/m'} + 'flask_app.task.process_qianwen_long': {'rate_limit': '250/m'} } # 可选:加载更多配置项(从环境变量或直接配置) diff --git a/flask_app/routes/routes.py b/flask_app/routes/routes.py index 1046fd1..1a1143d 100644 --- a/flask_app/routes/routes.py +++ b/flask_app/routes/routes.py @@ -1,6 +1,6 @@ # flask_project/flask_app/routes.py from flask import request, jsonify -from flask_app.task import process_qianwen_long +from flask_app.tasks import process_qianwen_long def register_routes(app): @app.route('/api/qianwen_long', methods=['POST']) diff --git a/flask_app/task.py b/flask_app/tasks.py similarity index 87% rename from flask_app/task.py rename to flask_app/tasks.py index a7456cf..95c15ec 100644 --- a/flask_app/task.py +++ b/flask_app/tasks.py @@ -4,7 +4,8 @@ from flask_app.general.通义千问long import qianwen_long @celery_app.task( - name='tasks.process_qianwen_long', + name='flask_app.task.process_qianwen_long', + bind=True, soft_time_limit=600, # 10分钟后发出超时信号 time_limit=660 )