From a2bd20eb0d8ab18cedd450e75d0cb01848b26825 Mon Sep 17 00:00:00 2001
From: zy123 <646228430@qq.com>
Date: Mon, 25 Nov 2024 17:09:32 +0800
Subject: [PATCH] 11.25 qianwen-long

---
 flask_app/celery_app.py         | 2 +-
 flask_app/routes/routes.py      | 2 +-
 flask_app/{task.py => tasks.py} | 3 ++-
 3 files changed, 4 insertions(+), 3 deletions(-)
 rename flask_app/{task.py => tasks.py} (87%)

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
 )