@@ -1056,14 +1056,16 @@ async def import_agent_by_agent_id(
10561056 regeneration_model_id = business_logic_model_id or model_id
10571057 if regeneration_model_id :
10581058 try :
1059- agent_name = _regenerate_agent_name_with_llm (
1059+ # Offload blocking LLM regeneration to a thread to avoid blocking the event loop
1060+ agent_name = await asyncio .to_thread (
1061+ _regenerate_agent_name_with_llm ,
10601062 original_name = agent_name ,
10611063 existing_names = existing_names ,
10621064 task_description = import_agent_info .business_description or import_agent_info .description or "" ,
10631065 model_id = regeneration_model_id ,
10641066 tenant_id = tenant_id ,
10651067 language = LANGUAGE ["ZH" ], # Default to Chinese, can be enhanced later
1066- agents_cache = all_agents
1068+ agents_cache = all_agents ,
10671069 )
10681070 logger .info (f"Regenerated agent name: '{ agent_name } '" )
10691071 except Exception as e :
@@ -1088,14 +1090,16 @@ async def import_agent_by_agent_id(
10881090 regeneration_model_id = business_logic_model_id or model_id
10891091 if regeneration_model_id :
10901092 try :
1091- agent_display_name = _regenerate_agent_display_name_with_llm (
1093+ # Offload blocking LLM regeneration to a thread to avoid blocking the event loop
1094+ agent_display_name = await asyncio .to_thread (
1095+ _regenerate_agent_display_name_with_llm ,
10921096 original_display_name = agent_display_name ,
10931097 existing_display_names = existing_display_names ,
10941098 task_description = import_agent_info .business_description or import_agent_info .description or "" ,
10951099 model_id = regeneration_model_id ,
10961100 tenant_id = tenant_id ,
10971101 language = LANGUAGE ["ZH" ], # Default to Chinese, can be enhanced later
1098- agents_cache = all_agents
1102+ agents_cache = all_agents ,
10991103 )
11001104 logger .info (f"Regenerated agent display_name: '{ agent_display_name } '" )
11011105 except Exception as e :
0 commit comments