Merge pull request #157 from Fr4nc3/main

fix: missing context

Author: Fr4nc3

src/backend/kernel_agents/agent_base.py

@@ -161,7 +161,7 @@ async def handle_action_request(self, action_request: ActionRequest) -> str:
             #     thread=step.session_id
             # )  # AzureAIAgentThread(thread_id=step.session_id)
             async_generator = self._agent.invoke(
-                messages=f"{action_request.action}\n\nPlease perform this action",
+                messages=f"{str(self._chat_history)}\n\nPlease perform this action",
                 thread=thread,
             )
 

src/backend/kernel_agents/group_chat_manager.py

@@ -198,7 +198,7 @@ class Step(BaseDataModel):
         )
         if plan.human_clarification_response:
             received_human_feedback_on_plan = (
-                plan.human_clarification_response
+                f"{plan.human_clarification_request}: {plan.human_clarification_response}"
                 + " This information may or may not be relevant to the step you are executing - it was feedback provided by the human user on the overall plan, which includes multiple steps, not just the one you are actioning now."
             )
         else:
@@ -313,6 +313,12 @@ async def _execute_step(self, session_id: str, step: Step):
         formatted_string = ""
         formatted_string += "<conversation_history>Here is the conversation history so far for the current plan. This information may or may not be relevant to the step you have been asked to execute."
         formatted_string += f"The user's task was:\n{plan.summary}\n\n"
+        formatted_string += (
+            f" human_clarification_request:\n{plan.human_clarification_request}\n\n"
+        )
+        formatted_string += (
+            f" human_clarification_response:\n{plan.human_clarification_response}\n\n"
+        )
         formatted_string += (
             "The conversation between the previous agents so far is below:\n"
         )
@@ -323,7 +329,7 @@ async def _execute_step(self, session_id: str, step: Step):
                 break
             formatted_string += f"Step {i}\n"
             formatted_string += f"{AgentType.GROUP_CHAT_MANAGER.value}: {step.action}\n"
-            formatted_string += f"{step.agent.name}: {step.agent_reply}\n"
+            formatted_string += f"{step.agent.value}: {step.agent_reply}\n"
         formatted_string += "<conversation_history \\>"
 
         logging.info(f"Formatted string: {formatted_string}")

src/backend/kernel_agents/planner_agent.py

@@ -181,7 +181,7 @@ async def handle_input_task(self, input_task: InputTask) -> str:
                     user_id=self._user_id,
                     plan_id=plan.id,
                     content=f"Generated a plan with {len(steps)} steps. Click the blue check box beside each step to complete it, click the x to remove this step.",
-                    source="PlannerAgent",
+                    source=AgentType.PLANNER.value,
                     step_id="",
                 )
             )
@@ -193,7 +193,7 @@ async def handle_input_task(self, input_task: InputTask) -> str:
                     "user_id": self._user_id,
                     "plan_id": plan.id,
                     "content": f"Generated a plan with {len(steps)} steps. Click the blue check box beside each step to complete it, click the x to remove this step.",
-                    "source": "PlannerAgent",
+                    "source": AgentType.PLANNER.value,
                 },
             )
 
@@ -208,7 +208,7 @@ async def handle_input_task(self, input_task: InputTask) -> str:
                         user_id=self._user_id,
                         plan_id=plan.id,
                         content=f"I require additional information before we can proceed: {plan.human_clarification_request}",
-                        source="PlannerAgent",
+                        source=AgentType.PLANNER.value,
                         step_id="",
                     )
                 )
@@ -220,7 +220,7 @@ async def handle_input_task(self, input_task: InputTask) -> str:
                         "user_id": self._user_id,
                         "plan_id": plan.id,
                         "content": f"I require additional information before we can proceed: {plan.human_clarification_request}",
-                        "source": "PlannerAgent",
+                        "source": AgentType.PLANNER.value,
                     },
                 )
 
@@ -275,7 +275,7 @@ async def handle_plan_clarification(self, kernel_arguments: KernelArguments) ->
                 user_id=self._user_id,
                 plan_id="",
                 content="Thanks. The plan has been updated.",
-                source="PlannerAgent",
+                source=AgentType.PLANNER.value,
                 step_id="",
             )
         )
@@ -286,7 +286,7 @@ async def handle_plan_clarification(self, kernel_arguments: KernelArguments) ->
                 "session_id": session_id,
                 "user_id": self._user_id,
                 "content": "Thanks. The plan has been updated.",
-                "source": "PlannerAgent",
+                "source": AgentType.PLANNER.value,
             },
         )
 
@@ -508,7 +508,7 @@ async def _create_structured_plan(
                         "user_id": self._user_id,
                         "error": str(e),
                         "description": input_task.description,
-                        "source": "PlannerAgent",
+                        "source": AgentType.PLANNER.value,
                     },
                 )
             except Exception as event_error: