Formatting

Author: holtskinner

.github/actions/spelling/allow.txt

@@ -29,8 +29,10 @@ datamodel
 drivername
 DSNs
 dunders
+eid
 euo
 EUR
+evt
 excinfo
 fernet
 fetchrow
@@ -82,8 +84,6 @@ testuuid
 Tful
 typeerror
 vulnz
-eid
-evt
-XREAD
 xread
+XREAD
 xrevrange

tests/server/events/test_redis_event_consumer.py

@@ -1,4 +1,5 @@
 import asyncio
+
 import pytest
 
 from a2a.server.events.redis_event_consumer import RedisEventConsumer

tests/server/events/test_redis_event_queue.py

@@ -1,5 +1,6 @@
 import asyncio
 import json
+
 import pytest
 
 from a2a.server.events.redis_event_queue import RedisEventQueue

tests/server/request_handlers/test_default_request_handler.py

@@ -2459,6 +2459,7 @@ async def test_on_message_send_stream_task_id_provided_but_task_not_found():
 def test_init_with_default_queue_manager_issues_deprecation_warning():
     """Test that initializing with default queue_manager issues deprecation warning."""
     import warnings
+
     from unittest.mock import MagicMock
 
     with warnings.catch_warnings(record=True) as w:
@@ -2477,6 +2478,7 @@ def test_init_with_default_queue_manager_issues_deprecation_warning():
 def test_init_with_explicit_queue_manager_no_warning():
     """Test that initializing with explicit queue_manager does not issue warning."""
     import warnings
+
     from unittest.mock import MagicMock
 
     with warnings.catch_warnings(record=True) as w:
@@ -2501,6 +2503,7 @@ def test_init_with_explicit_queue_manager_no_warning():
 async def test_init_with_disabled_fallback_raises_error():
     """Test that disabling fallback raises ValueError when queue_manager is None."""
     import os
+
     from unittest.mock import MagicMock
 
     # Set environment variable to disable fallback
@@ -2525,6 +2528,7 @@ async def test_init_with_disabled_fallback_false_allows_default():
     """Test that setting A2A_DISABLE_QUEUE_MANAGER_FALLBACK=false allows default behavior."""
     import os
     import warnings
+
     from unittest.mock import MagicMock
 
     # Set environment variable to explicitly allow fallback
@@ -2553,6 +2557,7 @@ async def test_init_with_disabled_fallback_false_allows_default():
 def test_environment_variable_parsing():
     """Test that environment variable accepts various true/false values."""
     import os
+
     from unittest.mock import MagicMock
 
     test_cases = [

tests/server/request_handlers/test_redis_request_handler.py

@@ -5,15 +5,15 @@ def __init__(self, redis_client=None, stream_prefix='a2a:task'):
 
     monkeypatch.setenv('A2A_FAKE', '1')
 
-    from a2a.server.request_handlers.redis_request_handler import (
-        create_redis_request_handler,
-    )
+    # Monkeypatch RedisQueueManager to our fake to avoid real redis import
+    import a2a.server.events.redis_queue_manager as rqm
+
     from a2a.server.request_handlers.default_request_handler import (
         DefaultRequestHandler,
     )
-
-    # Monkeypatch RedisQueueManager to our fake to avoid real redis import
-    import a2a.server.events.redis_queue_manager as rqm
+    from a2a.server.request_handlers.redis_request_handler import (
+        create_redis_request_handler,
+    )
 
     rqm.RedisQueueManager = FakeRedisQueueManager
 

tests/utils/test_redis_stream_writer.py

@@ -1,6 +1,7 @@
-import pytest
 from unittest.mock import AsyncMock, patch
 
+import pytest
+
 from a2a.types import TaskStatusUpdateEvent
 from a2a.utils.stream_write.redis_stream_writer import RedisStreamInjector
 
@@ -226,7 +227,7 @@ async def test_stream_message_with_message_object(self):
         injector._connected = True
 
         # Create a proper Message object with required fields
-        from a2a.types import Message, TextPart, Role
+        from a2a.types import Message, Role, TextPart
 
         message = Message(
             message_id='msg-123',