fix: sessions code fence, a2a tests & lint

src/strands/models/anthropic.py

@@ -414,7 +414,7 @@ async def structured_output(
         stop_reason, messages, _, _ = event["stop"]
 
         if stop_reason != "tool_use":
-            raise ValueError(f"Model returned stop_reason: {stop_reason} instead of \"tool_use\".")
+            raise ValueError(f'Model returned stop_reason: {stop_reason} instead of "tool_use".')
 
         content = messages["content"]
         output_response: dict[str, Any] | None = None

src/strands/models/bedrock.py

@@ -631,7 +631,7 @@ async def structured_output(
         stop_reason, messages, _, _ = event["stop"]
 
         if stop_reason != "tool_use":
-            raise ValueError(f"Model returned stop_reason: {stop_reason} instead of \"tool_use\".")
+            raise ValueError(f'Model returned stop_reason: {stop_reason} instead of "tool_use".')
 
         content = messages["content"]
         output_response: dict[str, Any] | None = None

src/strands/multiagent/a2a/executor.py

@@ -61,7 +61,7 @@ async def execute(
             task = new_task(context.message)  # type: ignore
             await event_queue.enqueue_event(task)
 
-        updater = TaskUpdater(event_queue, task.id, task.contextId)
+        updater = TaskUpdater(event_queue, task.id, task.context_id)
 
         try:
             await self._execute_streaming(context, updater)

src/strands/session/file_session_manager.py

@@ -23,6 +23,7 @@ class FileSessionManager(RepositorySessionManager, SessionRepository):
     """File-based session manager for local filesystem storage.
 
     Creates the following filesystem structure for the session storage:
+    ```bash
     /<sessions_dir>/
     └── session_<session_id>/
         ├── session.json                # Session metadata
@@ -32,7 +33,7 @@ class FileSessionManager(RepositorySessionManager, SessionRepository):
                 └── messages/
                     ├── message_<id1>.json
                     └── message_<id2>.json
-
+    ```
     """
 
     def __init__(self, session_id: str, storage_dir: Optional[str] = None, **kwargs: Any):

src/strands/session/s3_session_manager.py

@@ -24,6 +24,7 @@ class S3SessionManager(RepositorySessionManager, SessionRepository):
     """S3-based session manager for cloud storage.
 
     Creates the following filesystem structure for the session storage:
+    ```bash
     /<sessions_dir>/
     └── session_<session_id>/
         ├── session.json                # Session metadata
@@ -33,7 +34,7 @@ class S3SessionManager(RepositorySessionManager, SessionRepository):
                 └── messages/
                     ├── message_<id1>.json
                     └── message_<id2>.json
-
+    ```
     """
 
     def __init__(

tests/strands/multiagent/a2a/test_executor.py

@@ -36,7 +36,7 @@ async def mock_stream(user_input):
     # Mock the task creation
     mock_task = MagicMock()
     mock_task.id = "test-task-id"
-    mock_task.contextId = "test-context-id"
+    mock_task.context_id = "test-context-id"
     mock_request_context.current_task = mock_task
 
     await executor.execute(mock_request_context, mock_event_queue)
@@ -65,7 +65,7 @@ async def mock_stream(user_input):
     # Mock the task creation
     mock_task = MagicMock()
     mock_task.id = "test-task-id"
-    mock_task.contextId = "test-context-id"
+    mock_task.context_id = "test-context-id"
     mock_request_context.current_task = mock_task
 
     await executor.execute(mock_request_context, mock_event_queue)
@@ -95,7 +95,7 @@ async def mock_stream(user_input):
     # Mock the task creation
     mock_task = MagicMock()
     mock_task.id = "test-task-id"
-    mock_task.contextId = "test-context-id"
+    mock_task.context_id = "test-context-id"
     mock_request_context.current_task = mock_task
 
     await executor.execute(mock_request_context, mock_event_queue)
@@ -125,7 +125,7 @@ async def mock_stream(user_input):
     # Mock the task creation
     mock_task = MagicMock()
     mock_task.id = "test-task-id"
-    mock_task.contextId = "test-context-id"
+    mock_task.context_id = "test-context-id"
     mock_request_context.current_task = mock_task
 
     await executor.execute(mock_request_context, mock_event_queue)
@@ -156,7 +156,7 @@ async def mock_stream(user_input):
     mock_request_context.current_task = None
 
     with patch("strands.multiagent.a2a.executor.new_task") as mock_new_task:
-        mock_new_task.return_value = MagicMock(id="new-task-id", contextId="new-context-id")
+        mock_new_task.return_value = MagicMock(id="new-task-id", context_id="new-context-id")
 
         await executor.execute(mock_request_context, mock_event_queue)
 
@@ -180,7 +180,7 @@ async def test_execute_streaming_mode_handles_agent_exception(
     # Mock the task creation
     mock_task = MagicMock()
     mock_task.id = "test-task-id"
-    mock_task.contextId = "test-context-id"
+    mock_task.context_id = "test-context-id"
     mock_request_context.current_task = mock_task
 
     with pytest.raises(ServerError):
@@ -210,7 +210,7 @@ async def test_handle_agent_result_with_none_result(mock_strands_agent, mock_req
     # Mock the task creation
     mock_task = MagicMock()
     mock_task.id = "test-task-id"
-    mock_task.contextId = "test-context-id"
+    mock_task.context_id = "test-context-id"
     mock_request_context.current_task = mock_task
 
     # Mock TaskUpdater
@@ -235,7 +235,7 @@ async def test_handle_agent_result_with_result_but_no_message(
     # Mock the task creation
     mock_task = MagicMock()
     mock_task.id = "test-task-id"
-    mock_task.contextId = "test-context-id"
+    mock_task.context_id = "test-context-id"
     mock_request_context.current_task = mock_task
 
     # Mock TaskUpdater

tests/strands/multiagent/a2a/test_server.py

@@ -87,8 +87,8 @@ def test_public_agent_card(mock_strands_agent):
     assert card.description == "A test agent for unit testing"
     assert card.url == "http://0.0.0.0:9000/"
     assert card.version == "0.0.1"
-    assert card.defaultInputModes == ["text"]
-    assert card.defaultOutputModes == ["text"]
+    assert card.default_input_modes == ["text"]
+    assert card.default_output_modes == ["text"]
     assert card.skills == []
     assert card.capabilities == a2a_agent.capabilities