You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
Can you A2A server handle multiple concurrent request. The way A2A Server initialized , it take agent object as parameter. The agent once initialized with a session id. Will this be able to handle concurrent request separately as different session. I have done the implementation but I have facing below issue.
Error
raise error_class(parsed_response, operation_name)
botocore.errorfactory.ValidationException: An error occurred (ValidationException) when calling the ConverseStream operation: Expected toolResult blocks at messages.34.content for the following Ids: tooluse_DkTE_kXERpmGkxxGc31jhw, but found: tooluse__WdnNdJ3RH-cpf42IPlVsA
└ Bedrock region: us-west-2
└ Model id: arn:aws:bedrock:::inference-profile/global.anthropic.claude-sonnet-4-20250514-v1:0
ERROR | strands.multiagent.a2a.executor | Error in streaming execution
Traceback (most recent call last):
File "/root/a2a/.venv/lib64/python3.11/site-packages/strands/event_loop/event_loop.py", line 189, in event_loop_cycle
async for tool_event in tool_events:
File "/root/a2a/.venv/lib64/python3.11/site-packages/strands/event_loop/event_loop.py", line 531, in _handle_tool_execution
async for event in events:
File "/root/a2a/.venv/lib64/python3.11/site-packages/strands/event_loop/event_loop.py", line 277, in recurse_event_loop
async for event in events:
File "/root/a2a/.venv/lib64/python3.11/site-packages/strands/event_loop/event_loop.py", line 152, in event_loop_cycle
async for model_event in model_events:
File "/root/a2a/.venv/lib64/python3.11/site-packages/strands/event_loop/event_loop.py", line 396, in _handle_model_execution
raise e
File "/root/a2a/.venv/lib64/python3.11/site-packages/strands/event_loop/event_loop.py", line 337, in _handle_model_execution
async for event in stream_messages(
File "/root/a2a/.venv/lib64/python3.11/site-packages/strands/event_loop/streaming.py", line 454, in stream_messages
async for event in process_stream(chunks, start_time):
File "/root/a2a/.venv/lib64/python3.11/site-packages/strands/event_loop/streaming.py", line 388, in process_stream
async for chunk in chunks:
File "/root/a2a/.venv/lib64/python3.11/site-packages/strands/models/bedrock.py", line 647, in stream
await task
File "/usr/lib64/python3.11/asyncio/threads.py", line 25, in to_thread
return await loop.run_in_executor(None, func_call)
^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
File "/usr/lib64/python3.11/concurrent/futures/thread.py", line 58, in run
result = self.fn(*self.args, **self.kwargs)
^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
File "/root/a2a/.venv/lib64/python3.11/site-packages/opentelemetry/instrumentation/threading/init.py", line 171, in wrapped_func
return original_func(*func_args, **func_kwargs)
^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
File "/root/a2a/.venv/lib64/python3.11/site-packages/strands/models/bedrock.py", line 768, in _stream
raise e
File "/root/a2a/.venv/lib64/python3.11/site-packages/strands/models/bedrock.py", line 683, in _stream
response = self.client.converse_stream(**request)
^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
File "/root/a2a/.venv/lib64/python3.11/site-packages/botocore/client.py", line 602, in _api_call
return self._make_api_call(operation_name, kwargs)
^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
File "/root/a2a/.venv/lib64/python3.11/site-packages/botocore/context.py", line 123, in wrapper
return func(*args, **kwargs)
^^^^^^^^^^^^^^^^^^^^^
File "/root/a2a/.venv/lib64/python3.11/site-packages/botocore/client.py", line 1078, in _make_api_call
raise error_class(parsed_response, operation_name)
reacted with thumbs up emoji reacted with thumbs down emoji reacted with laugh emoji reacted with hooray emoji reacted with confused emoji reacted with heart emoji reacted with rocket emoji reacted with eyes emoji
Uh oh!
There was an error while loading. Please reload this page.
-
Can you A2A server handle multiple concurrent request. The way A2A Server initialized , it take agent object as parameter. The agent once initialized with a session id. Will this be able to handle concurrent request separately as different session. I have done the implementation but I have facing below issue.
Error
raise error_class(parsed_response, operation_name)
botocore.errorfactory.ValidationException: An error occurred (ValidationException) when calling the ConverseStream operation: Expected toolResult blocks at messages.34.content for the following Ids: tooluse_DkTE_kXERpmGkxxGc31jhw, but found: tooluse__WdnNdJ3RH-cpf42IPlVsA
└ Bedrock region: us-west-2
└ Model id: arn:aws:bedrock:::inference-profile/global.anthropic.claude-sonnet-4-20250514-v1:0
ERROR | strands.multiagent.a2a.executor | Error in streaming execution
Traceback (most recent call last):
File "/root/a2a/.venv/lib64/python3.11/site-packages/strands/event_loop/event_loop.py", line 189, in event_loop_cycle
async for tool_event in tool_events:
File "/root/a2a/.venv/lib64/python3.11/site-packages/strands/event_loop/event_loop.py", line 531, in _handle_tool_execution
async for event in events:
File "/root/a2a/.venv/lib64/python3.11/site-packages/strands/event_loop/event_loop.py", line 277, in recurse_event_loop
async for event in events:
File "/root/a2a/.venv/lib64/python3.11/site-packages/strands/event_loop/event_loop.py", line 152, in event_loop_cycle
async for model_event in model_events:
File "/root/a2a/.venv/lib64/python3.11/site-packages/strands/event_loop/event_loop.py", line 396, in _handle_model_execution
raise e
File "/root/a2a/.venv/lib64/python3.11/site-packages/strands/event_loop/event_loop.py", line 337, in _handle_model_execution
async for event in stream_messages(
File "/root/a2a/.venv/lib64/python3.11/site-packages/strands/event_loop/streaming.py", line 454, in stream_messages
async for event in process_stream(chunks, start_time):
File "/root/a2a/.venv/lib64/python3.11/site-packages/strands/event_loop/streaming.py", line 388, in process_stream
async for chunk in chunks:
File "/root/a2a/.venv/lib64/python3.11/site-packages/strands/models/bedrock.py", line 647, in stream
await task
File "/usr/lib64/python3.11/asyncio/threads.py", line 25, in to_thread
return await loop.run_in_executor(None, func_call)
^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
File "/usr/lib64/python3.11/concurrent/futures/thread.py", line 58, in run
result = self.fn(*self.args, **self.kwargs)
^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
File "/root/a2a/.venv/lib64/python3.11/site-packages/opentelemetry/instrumentation/threading/init.py", line 171, in wrapped_func
return original_func(*func_args, **func_kwargs)
^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
File "/root/a2a/.venv/lib64/python3.11/site-packages/strands/models/bedrock.py", line 768, in _stream
raise e
File "/root/a2a/.venv/lib64/python3.11/site-packages/strands/models/bedrock.py", line 683, in _stream
response = self.client.converse_stream(**request)
^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
File "/root/a2a/.venv/lib64/python3.11/site-packages/botocore/client.py", line 602, in _api_call
return self._make_api_call(operation_name, kwargs)
^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
File "/root/a2a/.venv/lib64/python3.11/site-packages/botocore/context.py", line 123, in wrapper
return func(*args, **kwargs)
^^^^^^^^^^^^^^^^^^^^^
File "/root/a2a/.venv/lib64/python3.11/site-packages/botocore/client.py", line 1078, in _make_api_call
raise error_class(parsed_response, operation_name)
Beta Was this translation helpful? Give feedback.
All reactions