FDP-Backend_Changes

Author: UtkarshMishra-Microsoft

src/backend/app_config.py

@@ -49,9 +49,7 @@ def __init__(self):
         self.AZURE_AI_SUBSCRIPTION_ID = self._get_required("AZURE_AI_SUBSCRIPTION_ID")
         self.AZURE_AI_RESOURCE_GROUP = self._get_required("AZURE_AI_RESOURCE_GROUP")
         self.AZURE_AI_PROJECT_NAME = self._get_required("AZURE_AI_PROJECT_NAME")
-        self.AZURE_AI_AGENT_PROJECT_CONNECTION_STRING = self._get_required(
-            "AZURE_AI_AGENT_PROJECT_CONNECTION_STRING"
-        )
+        self.AZURE_AI_AGENT_PROJECT_ENDPOINT = self._get_required("AZURE_AI_AGENT_PROJECT_ENDPOINT")
 
         # Cached clients and resources
         self._azure_credentials = None
@@ -177,10 +175,8 @@ def get_ai_project_client(self):
                     "Unable to acquire Azure credentials; ensure DefaultAzureCredential is configured"
                 )
 
-            connection_string = self.AZURE_AI_AGENT_PROJECT_CONNECTION_STRING
-            self._ai_project_client = AIProjectClient.from_connection_string(
-                credential=credential, conn_str=connection_string
-            )
+            endpoint = self.AZURE_AI_AGENT_PROJECT_ENDPOINT
+            self._ai_project_client = AIProjectClient(endpoint=endpoint, credential=credential)
 
             return self._ai_project_client
         except Exception as exc:

src/backend/app_kernel.py

@@ -35,18 +35,18 @@
 from utils_kernel import initialize_runtime_and_context, rai_success
 
 # Check if the Application Insights Instrumentation Key is set in the environment variables
-connection_string = os.getenv("APPLICATIONINSIGHTS_CONNECTION_STRING")
-if connection_string:
+#connection_string = os.getenv("APPLICATIONINSIGHTS_CONNECTION_STRING")
+#if connection_string:
     # Configure Application Insights if the Instrumentation Key is found
     #configure_azure_monitor(connection_string=connection_string)
-    logging.info(
-        "Application Insights configured with the provided Instrumentation Key"
-    )
-else:
-    # Log a warning if the Instrumentation Key is not found
-    logging.warning(
-        "No Application Insights Instrumentation Key found. Skipping configuration"
-    )
+#    logging.info(
+#        "Application Insights configured with the provided Instrumentation Key"
+#    )
+#else:
+#    # Log a warning if the Instrumentation Key is not found
+#    logging.warning(
+#        "No Application Insights Instrumentation Key found. Skipping configuration"
+#    )
 
 # Configure logging
 logging.basicConfig(level=logging.INFO)

src/backend/config_kernel.py

@@ -26,9 +26,7 @@ class Config:
     AZURE_AI_SUBSCRIPTION_ID = config.AZURE_AI_SUBSCRIPTION_ID
     AZURE_AI_RESOURCE_GROUP = config.AZURE_AI_RESOURCE_GROUP
     AZURE_AI_PROJECT_NAME = config.AZURE_AI_PROJECT_NAME
-    AZURE_AI_AGENT_PROJECT_CONNECTION_STRING = (
-        config.AZURE_AI_AGENT_PROJECT_CONNECTION_STRING
-    )
+    AZURE_AI_AGENT_PROJECT_ENDPOINT = config.AZURE_AI_AGENT_PROJECT_ENDPOINT
 
     @staticmethod
     def GetAzureCredentials():

src/backend/kernel_agents/agent_base.py

@@ -8,7 +8,8 @@
 from event_utils import track_event_if_configured
 from models.messages_kernel import (ActionRequest, ActionResponse,
                                     AgentMessage, Step, StepStatus)
-from semantic_kernel.agents.azure_ai.azure_ai_agent import AzureAIAgent
+from semantic_kernel.agents.azure_ai.azure_ai_agent import AzureAIAgent, AzureAIAgentThread
+from semantic_kernel.agents.azure_ai.azure_ai_agent_settings import AzureAIAgentSettings
 from semantic_kernel.functions import KernelFunction
 
 # Default formatting instructions used across agents

src/backend/kernel_agents/agent_factory.py

@@ -6,7 +6,7 @@
 
 # Import the new AppConfig instance
 from app_config import config
-from azure.ai.projects.models import (ResponseFormatJsonSchema,
+from azure.ai.agents.models import (ResponseFormatJsonSchema,
                                       ResponseFormatJsonSchemaType)
 from context.cosmos_memory_kernel import CosmosMemoryContext
 from kernel_agents.agent_base import BaseAgent
@@ -22,8 +22,8 @@
 from kernel_agents.tech_support_agent import TechSupportAgent
 from models.messages_kernel import AgentType, PlannerResponsePlan
 # pylint:disable=E0611
-from semantic_kernel.agents.azure_ai.azure_ai_agent import AzureAIAgent
-
+from semantic_kernel.agents.azure_ai.azure_ai_agent import AzureAIAgent, AzureAIAgentThread
+from semantic_kernel.agents.azure_ai.azure_ai_agent_settings import AzureAIAgentSettings
 logger = logging.getLogger(__name__)
 
 
@@ -265,13 +265,6 @@ async def create_all_agents(
             temperature=temperature,
             agent_instances=agent_instances,  # Pass agent instances to the planner
             client=client,
-            response_format=ResponseFormatJsonSchemaType(
-                json_schema=ResponseFormatJsonSchema(
-                    name=PlannerResponsePlan.__name__,
-                    description=f"respond with {PlannerResponsePlan.__name__.lower()}",
-                    schema=PlannerResponsePlan.model_json_schema(),
-                )
-            ),
         )
         agent_instances[AgentType.PLANNER.value] = (
             planner_agent  # to pass it to group chat manager

src/backend/kernel_agents/planner_agent.py

@@ -3,7 +3,7 @@
 import uuid
 from typing import Any, Dict, List, Optional, Tuple
 
-from azure.ai.projects.models import (ResponseFormatJsonSchema,
+from azure.ai.agents.models import (ResponseFormatJsonSchema,
                                       ResponseFormatJsonSchemaType)
 from context.cosmos_memory_kernel import CosmosMemoryContext
 from event_utils import track_event_if_configured
@@ -133,37 +133,43 @@ async def create(
         try:
             logging.info("Initializing PlannerAgent from async init azure AI Agent")
 
+            # Construct response_format with the required 'type' field
+            response_format = {
+                "type": "json_schema",  # Add the missing type field
+                "json_schema": {
+                    "name": PlannerResponsePlan.__name__,
+                    "description": f"respond with {PlannerResponsePlan.__name__.lower()}",
+                    "schema": PlannerResponsePlan.model_json_schema()
+                }
+            }
+
             # Create the Azure AI Agent using AppConfig with string instructions
             agent_definition = await cls._create_azure_ai_agent_definition(
                 agent_name=agent_name,
-                instructions=cls._get_template(),  # Pass the formatted string, not an object
+                instructions=cls._get_template(),  # Pass the formatted string
                 temperature=0.0,
-                response_format=ResponseFormatJsonSchemaType(
-                    json_schema=ResponseFormatJsonSchema(
-                        name=PlannerResponsePlan.__name__,
-                        description=f"respond with {PlannerResponsePlan.__name__.lower()}",
-                        schema=PlannerResponsePlan.model_json_schema(),
-                    )
-                ),
+                response_format=response_format,
             )
 
-            return cls(
-                session_id=session_id,
-                user_id=user_id,
-                memory_store=memory_store,
-                tools=tools,
-                system_message=system_message,
-                agent_name=agent_name,
-                available_agents=available_agents,
-                agent_instances=agent_instances,
-                client=client,
-                definition=agent_definition,
-            )
-
-        except Exception as e:
-            logging.error(f"Failed to create Azure AI Agent for PlannerAgent: {e}")
+        except Exception as exc:
+            logging.error("Error initializing PlannerAgent definition: %s", exc)
             raise
 
+        return cls(
+            session_id=session_id,
+            user_id=user_id,
+            memory_store=memory_store,
+            tools=tools,
+            system_message=system_message,
+            agent_name=agent_name,
+            available_agents=available_agents,
+            agent_instances=agent_instances,
+            client=client,
+            definition=agent_definition,
+        )
+
+
+
     async def handle_input_task(self, input_task: InputTask) -> str:
         """Handle the initial input task from the user.
 

src/backend/pyproject.toml

@@ -26,6 +26,6 @@ dependencies = [
     "pytest-cov==5.0.0",
     "python-dotenv>=1.1.0",
     "python-multipart>=0.0.20",
-    "semantic-kernel>=1.28.1",
+    "semantic-kernel>=1.32.2",
     "uvicorn>=0.34.2",
 ]

src/backend/requirements.txt

@@ -14,9 +14,9 @@ opentelemetry-instrumentation-fastapi
 opentelemetry-instrumentation-openai
 opentelemetry-exporter-otlp-proto-http
 
-semantic-kernel[azure]==1.28.1
-azure-ai-projects==1.0.0b10 
-openai 
+semantic-kernel[azure]==1.32.2
+azure-ai-projects==1.0.0b11
+openai==1.84.0 
 azure-ai-inference==1.0.0b9 
 azure-search-documents 
 azure-ai-evaluation