Ling0925
/
suna
mirror of https://github.com/kortix-ai/suna.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

fix non-stream async

This commit is contained in:
LE Quoc Dat 2025-04-18 04:41:55 +01:00
parent aae78a0667
commit 9beb4dc215
1 changed files with 5 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
backend/agentpress/thread_manager.py
View File

@ -334,15 +334,16 @@ Here are the XML tools available with examples:
else:
logger.debug("Processing non-streaming response")
try:
response = await self.response_processor.process_non_streaming_response(
# Return the async generator directly, don't await it
response_generator = self.response_processor.process_non_streaming_response(
llm_response=llm_response,
thread_id=thread_id,
config=processor_config
)
return response
return response_generator # Return the generator
except Exception as e:
logger.error(f"Error in non-streaming response: {str(e)}", exc_info=True)
raise
logger.error(f"Error setting up non-streaming response: {str(e)}", exc_info=True)
raise # Re-raise the exception to be caught by the outer handler
except Exception as e:
logger.error(f"Error in run_thread: {str(e)}", exc_info=True)