chore(a2a): lint/format

Author: jer

src/strands/multiagent/a2a/executor.py

@@ -46,13 +46,7 @@ class StrandsA2AExecutor(AgentExecutor):
     DEFAULT_FORMATS = {"document": "txt", "image": "png", "video": "mp4", "unknown": "txt"}
 
     # Handle special cases where format differs from extension
-    FORMAT_MAPPINGS = {
-        "jpg": "jpeg",
-        "htm": "html",
-        "3gp": "three_gp",
-        "3gpp": "three_gp",
-        "3g2": "three_gp"
-    }
+    FORMAT_MAPPINGS = {"jpg": "jpeg", "htm": "html", "3gp": "three_gp", "3gpp": "three_gp", "3g2": "three_gp"}
 
     def __init__(self, agent: SAAgent):
         """Initialize a StrandsA2AExecutor.
@@ -219,8 +213,8 @@ def _get_file_format_from_mime_type(self, mime_type: str | None, file_type: str)
         mime_type = mime_type.lower()
 
         # Extract subtype from MIME type and check existing format mappings
-        if '/' in mime_type:
-            subtype = mime_type.split('/')[-1]
+        if "/" in mime_type:
+            subtype = mime_type.split("/")[-1]
             if subtype in self.FORMAT_MAPPINGS:
                 return self.FORMAT_MAPPINGS[subtype]
 

tests/strands/multiagent/a2a/test_executor.py

@@ -813,7 +813,9 @@ def non_serializable():
 
 
 @pytest.mark.asyncio
-async def test_execute_streaming_mode_raises_error_for_empty_content_blocks(mock_strands_agent, mock_event_queue, mock_request_context):
+async def test_execute_streaming_mode_raises_error_for_empty_content_blocks(
+    mock_strands_agent, mock_event_queue, mock_request_context
+):
     """Test that execute raises ServerError when content blocks are empty after conversion."""
     executor = StrandsA2AExecutor(mock_strands_agent)
 
@@ -824,7 +826,7 @@ async def test_execute_streaming_mode_raises_error_for_empty_content_blocks(mock
     mock_request_context.message = mock_message
 
     # Mock the conversion to return empty list
-    with patch.object(executor, '_convert_a2a_parts_to_content_blocks', return_value=[]):
+    with patch.object(executor, "_convert_a2a_parts_to_content_blocks", return_value=[]):
         with pytest.raises(ServerError) as excinfo:
             await executor.execute(mock_request_context, mock_event_queue)