@@ -84,7 +84,7 @@ def generate_and_save_system_prompt_impl(agent_id: int,
8484 # 1. Real-time streaming push
8585 final_results = {"duty" : "" , "constraint" : "" , "few_shots" : "" , "agent_var_name" : "" , "agent_display_name" : "" ,
8686 "agent_description" : "" }
87-
87+
8888 # Get all existing agent names and display names for duplicate checking (only if not in create mode)
8989 all_agents = query_all_agent_info_by_tenant_id (tenant_id )
9090 existing_names = [
@@ -97,13 +97,13 @@ def generate_and_save_system_prompt_impl(agent_id: int,
9797 for agent in all_agents
9898 if agent .get ("display_name" ) and agent .get ("agent_id" ) != agent_id
9999 ]
100-
100+
101101 # Collect results and yield non-name fields immediately, but hold name fields for duplicate checking
102102 for result_data in generate_system_prompt (sub_agent_info_list , task_description , tool_info_list , tenant_id ,
103103 model_id , language ):
104104 result_type = result_data ["type" ]
105105 final_results [result_type ] = result_data ["content" ]
106-
106+
107107 # Yield non-name fields immediately
108108 if result_type not in ["agent_var_name" , "agent_display_name" ]:
109109 yield result_data
@@ -325,7 +325,7 @@ def _stream_results(produce_queue, latest, stop_flags, threads):
325325
326326 result_data = {
327327 "type" : tag ,
328- "content" : latest [tag ],
328+ "content" : latest [tag ]. strip () ,
329329 "is_complete" : True
330330 }
331331 yield result_data
0 commit comments