AI/dify
1
0
Fork 0
mirror of https://git.mirrors.martin98.com/https://github.com/langgenius/dify.git synced 2025-08-10 04:49:03 +08:00
Code Issues Packages Projects Releases Wiki Activity

fix(app_generator): improve error handling for closed file I/O operat… (#12073)

Browse Source 
Signed-off-by: -LAN- <laipz8200@outlook.com>
This commit is contained in:
-LAN- 2024-12-25 16:34:38 +08:00 committed by GitHub
parent 1885d3df99
commit 39ace9bdee
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
4 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
api/core/app/apps/advanced_chat/app_generator.py
View File

@ -383,7 +383,7 @@ class AdvancedChatAppGenerator(MessageBasedAppGenerator):
try: try:
return generate_task_pipeline.process() return generate_task_pipeline.process()
except ValueError as e: except ValueError as e:
if e.args[0] == "I/O operation on closed file.": # ignore this error if len(e.args) > 0 and e.args[0] == "I/O operation on closed file.": # ignore this error
raise GenerateTaskStoppedError() raise GenerateTaskStoppedError()
else: else:
logger.exception(f"Failed to process generate task pipeline, conversation_id: {conversation.id}") logger.exception(f"Failed to process generate task pipeline, conversation_id: {conversation.id}")

2
api/core/app/apps/message_based_app_generator.py
View File

@ -76,7 +76,7 @@ class MessageBasedAppGenerator(BaseAppGenerator):
try: try:
return generate_task_pipeline.process() return generate_task_pipeline.process()
except ValueError as e: except ValueError as e:
if e.args[0] == "I/O operation on closed file.": # ignore this error if len(e.args) > 0 and e.args[0] == "I/O operation on closed file.": # ignore this error
raise GenerateTaskStoppedError() raise GenerateTaskStoppedError()
else: else:
logger.exception(f"Failed to handle response, conversation_id: {conversation.id}") logger.exception(f"Failed to handle response, conversation_id: {conversation.id}")

2
api/core/app/apps/workflow/app_generator.py
View File

@ -309,7 +309,7 @@ class WorkflowAppGenerator(BaseAppGenerator):
try: try:
return generate_task_pipeline.process() return generate_task_pipeline.process()
except ValueError as e: except ValueError as e:
if e.args[0] == "I/O operation on closed file.": # ignore this error if len(e.args) > 0 and e.args[0] == "I/O operation on closed file.": # ignore this error
raise GenerateTaskStoppedError() raise GenerateTaskStoppedError()
else: else:
logger.exception( logger.exception(

2
api/core/tools/tool_engine.py
View File

@ -113,7 +113,7 @@ class ToolEngine:
error_response = f"tool invoke error: {e}" error_response = f"tool invoke error: {e}"
agent_tool_callback.on_tool_error(e) agent_tool_callback.on_tool_error(e)
except ToolEngineInvokeError as e: except ToolEngineInvokeError as e:
meta = e.args[0] meta = e.meta
error_response = f"tool invoke error: {meta.error}" error_response = f"tool invoke error: {meta.error}"
agent_tool_callback.on_tool_error(e) agent_tool_callback.on_tool_error(e)
return error_response, [], meta return error_response, [], meta