v2 changes

Author: Abdul-Microsoft

src/backend/v4/magentic_agents/foundry_agent.py

@@ -125,7 +125,9 @@ async def _create_azure_search_enabled_client(self, chatClient=None) -> Optional
         Returns:
             AzureAIClient | None
         """
+        print(f"[DEBUG _create_azure_search_enabled_client] Agent={self.agent_name}, chatClient={chatClient}, search_config={self.search}")
         if chatClient:
+            self.logger.info("Reusing existing chatClient for agent '%s' (already has Azure Search configured)", self.agent_name)
             return chatClient
 
         if not self.search:
@@ -234,12 +236,16 @@ async def _after_open(self) -> None:
 
         try:
             chatClient = await self.get_database_team_agent()
+            print(f"[DEBUG _after_open] Agent={self.agent_name}, _use_azure_search={self._use_azure_search}, search_config={self.search}, chatClient={chatClient}")
 
             if self._use_azure_search:
                 # Azure Search mode (skip MCP + Code Interpreter due to incompatibility)
                 self.logger.info(
-                    "Initializing agent in Azure AI Search mode (exclusive)."
+                    "Initializing agent '%s' in Azure AI Search mode (exclusive) with index=%s.",
+                    self.agent_name,
+                    getattr(self.search, "index_name", "N/A") if self.search else "N/A"
                 )
+                print(f"[DEBUG _after_open] Creating Azure Search client for {self.agent_name}")
                 chat_client = await self._create_azure_search_enabled_client(chatClient)
                 if not chat_client:
                     raise RuntimeError(

src/backend/v4/orchestration/orchestration_manager.py

@@ -16,6 +16,8 @@
     InMemoryCheckpointStorage,
     AgentRunUpdateEvent,
     GroupChatRequestSentEvent,
+    GroupChatResponseReceivedEvent,
+    ExecutorCompletedEvent,
     MagenticOrchestratorEvent,
     MagenticProgressLedger,
 )
@@ -45,6 +47,53 @@ def __init__(self):
         self.user_id: Optional[str] = None
         self.logger = self.__class__.logger
 
+    def _extract_response_text(self, data) -> str:
+        """
+        Extract text content from various agent_framework response types.
+        
+        Handles:
+        - ChatMessage: Extract .text
+        - AgentResponse: Extract .text
+        - AgentExecutorResponse: Extract from agent_response.text or full_conversation[-1].text
+        - List of any of the above
+        """
+        if data is None:
+            return ""
+        
+        # Direct ChatMessage
+        if isinstance(data, ChatMessage):
+            return data.text or ""
+        
+        # Has .text attribute directly (AgentResponse, etc.)
+        if hasattr(data, "text") and data.text:
+            return data.text
+        
+        # AgentExecutorResponse - has agent_response and full_conversation
+        if hasattr(data, "agent_response"):
+            # Try to get text from agent_response first
+            agent_resp = data.agent_response
+            if agent_resp and hasattr(agent_resp, "text") and agent_resp.text:
+                return agent_resp.text
+            # Fallback to last message in full_conversation
+            if hasattr(data, "full_conversation") and data.full_conversation:
+                last_msg = data.full_conversation[-1]
+                if isinstance(last_msg, ChatMessage) and last_msg.text:
+                    return last_msg.text
+        
+        # List of items - could be AgentExecutorResponse, ChatMessage, etc.
+        if isinstance(data, list) and len(data) > 0:
+            texts = []
+            for item in data:
+                # Recursively extract from each item
+                item_text = self._extract_response_text(item)
+                if item_text:
+                    texts.append(item_text)
+            if texts:
+                # Return the last non-empty response (most recent)
+                return texts[-1]
+        
+        return ""
+
     # ---------------------------
     # Orchestration construction
     # ---------------------------
@@ -336,6 +385,11 @@ async def run_orchestration(self, user_id: str, input_task) -> None:
             last_message_id: str | None = None
             async for event in workflow.run_stream(task_text):
                 try:
+                    # Only log non-streaming events (reduce noise)
+                    event_type_name = type(event).__name__
+                    if event_type_name != "AgentRunUpdateEvent":
+                        self.logger.info("[EVENT] %s", event_type_name)
+                    
                     # Handle orchestrator events (plan, progress ledger)
                     if isinstance(event, MagenticOrchestratorEvent):
                         self.logger.info(
@@ -378,6 +432,34 @@ async def run_orchestration(self, user_id: str, input_task) -> None:
                             event.participant_name
                         )
 
+                    # Handle group chat response received - THIS IS WHERE AGENT RESPONSES COME
+                    elif isinstance(event, GroupChatResponseReceivedEvent):
+                        self.logger.info(
+                            "[RESPONSE RECEIVED (round %d)] from agent: %s",
+                            event.round_index,
+                            event.participant_name
+                        )
+                        # Send the agent response to the UI
+                        if event.data:
+                            response_text = self._extract_response_text(event.data)
+                            
+                            if response_text:
+                                self.logger.info("Sending agent response to UI from %s", event.participant_name)
+                                agent_response_callback(
+                                    event.participant_name,
+                                    ChatMessage(role="assistant", text=response_text),
+                                    user_id,
+                                )
+
+                    # Handle executor completed - just log, don't send to UI (GroupChatResponseReceivedEvent handles that)
+                    elif isinstance(event, ExecutorCompletedEvent):
+                        self.logger.debug(
+                            "[EXECUTOR COMPLETED] agent: %s",
+                            event.executor_id
+                        )
+                        # Don't send to UI here - GroupChatResponseReceivedEvent already handles agent messages
+                        # This avoids duplicate messages
+
                     # Handle workflow output event (captures final result)
                     elif isinstance(event, WorkflowOutputEvent):
                         output_data = event.data