@@ -238,18 +238,19 @@ async def human_feedback_endpoint(human_feedback: HumanFeedback, request: Reques
238238 track_event_if_configured ("UserIdNotFound" , {"status_code" : 400 , "detail" : "no user" })
239239 raise HTTPException (status_code = 400 , detail = "no user" )
240240
241- # Get the agents for this session
242- agents = await get_agents (human_feedback .session_id , user_id )
241+ kernel , memory_store = await initialize_runtime_and_context (human_feedback .session_id , user_id )
242+ agents = await AgentFactory .create_all_agents (
243+ session_id = human_feedback .session_id ,
244+ user_id = user_id
245+ )
243246
244247 # Send the feedback to the human agent
245248 human_agent = agents [AgentType .HUMAN .value ]
246249
247- # Convert feedback to JSON for the kernel function
248- human_feedback_json = human_feedback .json ()
249250
250251 # Use the human agent to handle the feedback
251252 await human_agent .handle_human_feedback (
252- KernelArguments ( human_feedback_json = human_feedback_json )
253+ human_feedback = human_feedback
253254 )
254255
255256 track_event_if_configured (
@@ -413,15 +414,15 @@ async def approve_step_endpoint(
413414 agents = await get_agents (human_feedback .session_id , user_id )
414415
415416 # Send the approval to the group chat manager
416- group_chat_manager = agents ["GroupChatManager" ]
417+ group_chat_manager = agents [AgentType . GROUP_CHAT_MANAGER . value ]
417418
418419 # Handle the approval
419420 human_feedback_json = human_feedback .json ()
420421
421422 # First process with HumanAgent to update step status
422423 human_agent = agents [AgentType .HUMAN .value ]
423424 await human_agent .handle_human_feedback (
424- KernelArguments ( human_feedback_json = human_feedback_json )
425+ human_feedback_json = human_feedback_json
425426 )
426427
427428 # Then execute the next step with GroupChatManager
0 commit comments