@@ -23,10 +23,3 @@ def run_task(self, run_id: str, token_id: str, stream: bool = False):
finally:
session.close()
return None
-
-##统一的错误处理，最后集中到最后无法处理的错误的时候处理
-@celery_app.exception_handler(Exception)
-async def global_exception_handler(exc):
- print(f"An error occurred: {exc}")
- return {"message": "Internal server error, please check logs."}
