Merge pull request #459 from octo-patch/fix/issue-382-prevent-server-crash-on-query-error
fix: return HTTP 500 instead of crashing server on query errors
This commit is contained in:
@@ -278,8 +278,11 @@ async def process_query(request: QueryRequest):
|
|||||||
return JSONResponse(status_code=200, content=query_resp.jsonify())
|
return JSONResponse(status_code=200, content=query_resp.jsonify())
|
||||||
except Exception as e:
|
except Exception as e:
|
||||||
logger.error(f"An error occurred: {str(e)}")
|
logger.error(f"An error occurred: {str(e)}")
|
||||||
sys.exit(1)
|
query_resp.answer = f"An error occurred: {str(e)}"
|
||||||
|
query_resp.reasoning = f"Error: {str(e)}"
|
||||||
|
return JSONResponse(status_code=500, content=query_resp.jsonify())
|
||||||
finally:
|
finally:
|
||||||
|
is_generating = False
|
||||||
logger.info("Processing finished")
|
logger.info("Processing finished")
|
||||||
if config.getboolean('MAIN', 'save_session'):
|
if config.getboolean('MAIN', 'save_session'):
|
||||||
interaction.save_session()
|
interaction.save_session()
|
||||||
|
|||||||
@@ -271,8 +271,6 @@ class PlannerAgent(Agent):
|
|||||||
agents_tasks = []
|
agents_tasks = []
|
||||||
required_infos = None
|
required_infos = None
|
||||||
agents_work_result = dict()
|
agents_work_result = dict()
|
||||||
answer = ""
|
|
||||||
self.stop = False
|
|
||||||
|
|
||||||
self.status_message = "Making a plan..."
|
self.status_message = "Making a plan..."
|
||||||
agents_tasks = await self.make_plan(goal)
|
agents_tasks = await self.make_plan(goal)
|
||||||
|
|||||||
Reference in New Issue
Block a user