Skip to content

Commit a60ae43

Browse files
Eugene NavitaniucEugene Navitaniuc
authored andcommitted
adapt peer event response re-triggering to align with ADK-1.18.0's more strict validation
1 parent dcd46c8 commit a60ae43

File tree

1 file changed

+2
-9
lines changed

1 file changed

+2
-9
lines changed

src/solace_agent_mesh/agent/sac/component.py

Lines changed: 2 additions & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -793,14 +793,7 @@ async def _retrigger_agent_with_peer_responses(
793793
log_retrigger,
794794
len(new_response_parts),
795795
)
796-
new_adk_event = ADKEvent(
797-
invocation_id=paused_invocation_id,
798-
author=self.agent_name,
799-
content=adk_types.Content(role="tool", parts=new_response_parts),
800-
)
801-
await self.session_service.append_event(
802-
session=session, event=new_adk_event
803-
)
796+
new_tool_response_content = adk_types.Content(role="tool", parts=new_response_parts)
804797

805798
# Always use SSE streaming mode for the ADK runner, even on re-trigger.
806799
# This ensures that real-time callbacks for status updates and artifact
@@ -818,7 +811,7 @@ async def _retrigger_agent_with_peer_responses(
818811
)
819812
try:
820813
await run_adk_async_task_thread_wrapper(
821-
self, session, None, run_config, original_task_context
814+
self, session, new_tool_response_content, run_config, original_task_context, append_context_event=False
822815
)
823816
finally:
824817
log.info(

0 commit comments

Comments
 (0)