11.25 qianwen-long

flask_app/start_up.py

@@ -49,4 +49,4 @@ def create_app():
 #TODO:接口设置排队
 if __name__ == '__main__':
     app = create_app()
-    app.run(debug=True, host='0.0.0.0', port=5001)
+    app.run(debug=True, host='0.0.0.0', port=5000)

flask_app/task.py

@@ -1,4 +1,4 @@
-from celery_app import celery_app
+from flask_app.celery_app import celery_app
 from flask_app.general.通义千问long import qianwen_long
 
 
@@ -7,9 +7,9 @@ from flask_app.general.通义千问long import qianwen_long
     soft_time_limit=600,  # 10分钟后发出超时信号
     time_limit=660
 )
-def process_qianwen_long(self, file_id, user_query):
+def process_qianwen_long(file_id, user_query):
     try:
         return qianwen_long(file_id, user_query)
     except Exception as exc:
         # 如果发生异常，重试任务
-        raise self.retry(exc=exc, countdown=60)  # 60 秒后重试
+        print("no")