add thread location

Author: Fr4nc3

src/backend/kernel_agents/agent_base.py

@@ -189,8 +189,11 @@ async def handle_action_request(self, action_request: ActionRequest) -> str:
             # chat_history = self._chat_history.copy()
 
             # Call the agent to handle the action
+            # thread = self.client.agents.create_thread(thread_id=step.session_id)
+            thread = None
             async_generator = self._agent.invoke(
-                messages=f"{action_request.action}\n\nPlease perform this action"
+                messages=f"{action_request.action}\n\nPlease perform this action",
+                thread=thread,
             )
 
             response_content = ""
@@ -305,6 +308,13 @@ def create_dynamic_function(
             A dynamic async function that can be registered with the semantic kernel
         """
 
+        # Truncate function name to 64 characters if it exceeds the limit
+        if len(name) > 64:
+            logging.warning(
+                f"Function name '{name}' exceeds 64 characters (length: {len(name)}). Truncating to 64 characters."
+            )
+            name = name[:64]
+
         async def dynamic_function(**kwargs) -> str:
             try:
                 # Format the template with the provided kwargs

src/backend/kernel_agents/planner_agent.py

@@ -12,7 +12,11 @@
 import semantic_kernel as sk
 from semantic_kernel.functions import KernelFunction
 from semantic_kernel.functions.kernel_arguments import KernelArguments
-
+from semantic_kernel.agents import (
+    AzureAIAgent,
+    AzureAIAgentSettings,
+    AzureAIAgentThread,
+)
 from kernel_agents.agent_base import BaseAgent
 from context.cosmos_memory_kernel import CosmosMemoryContext
 from models.messages_kernel import (
@@ -319,12 +323,15 @@ async def _create_structured_plan(
 
             # Ensure we're using the right pattern for Azure AI agents with semantic kernel
             # Properly handle async generation
+            thread = None
+            # thread = self.client.agents.create_thread(thread_id=input_task.session_id)
             async_generator = self._azure_ai_agent.invoke(
                 arguments=kernel_args,
                 settings={
                     "temperature": 0.0,  # Keep temperature low for consistent planning
                     "max_tokens": 10096,  # Ensure we have enough tokens for the full plan
                 },
+                thread=thread,
             )
 
             # Call invoke with proper keyword arguments and JSON response schema