Fixes after merge

Author: ishymko

.github/workflows/linter.yaml

@@ -63,7 +63,7 @@ jobs:
                 "${{ steps.ruff-format.outcome }}" == "failure" || \
                 "${{ steps.mypy.outcome }}" == "failure" || \
                 "${{ steps.pyright.outcome }}" == "failure"]]; then
-# Disable due to not to block on "PR too large error"
+# Disable to not to block on "PR too large error"
 #               "${{ steps.jscpd.outcome }}" == "failure" ]]; then
             echo "One or more linting/checking steps failed."
             exit 1

.github/workflows/unit-tests.yml

@@ -36,7 +36,7 @@ jobs:
 
     strategy:
       matrix:
-        python-version: ["3.10", "3.13"]
+        python-version: ['3.10', '3.13']
     steps:
       - name: Checkout code
         uses: actions/checkout@v6
@@ -57,6 +57,6 @@ jobs:
       - name: Install dependencies
         run: uv sync --locked
       - name: Run tests and check coverage
-        run: uv run pytest --cov=a2a --cov-report term --cov-fail-under=85
+        run: uv run pytest --cov=a2a --cov-report term --cov-fail-under=88
       - name: Show coverage summary in log
         run: uv run coverage report

.github/workflows/update-a2a-types.yml

@@ -17,7 +17,7 @@ jobs:
       - name: Set up Python
         uses: actions/setup-python@v6
         with:
-          python-version: "3.10"
+          python-version: '3.10'
       - name: Install uv
         uses: astral-sh/setup-uv@v7
       - name: Configure uv shell
@@ -41,8 +41,8 @@ jobs:
           token: ${{ secrets.A2A_BOT_PAT }}
           committer: a2a-bot <a2a-bot@google.com>
           author: a2a-bot <a2a-bot@google.com>
-          commit-message: "${{ github.event.client_payload.message }}"
-          title: "${{ github.event.client_payload.message }}"
+          commit-message: '${{ github.event.client_payload.message }}'
+          title: '${{ github.event.client_payload.message }}'
           body: |
             Commit: https://github.com/a2aproject/A2A/commit/${{ github.event.client_payload.sha }}
           branch: auto-update-a2a-types-${{ github.event.client_payload.sha }}

src/a2a/client/transports/jsonrpc.py

@@ -176,6 +176,8 @@ async def send_message_streaming(
             try:
                 event_source.response.raise_for_status()
                 async for sse in event_source.aiter_sse():
+                    if not sse.data:
+                        continue
                     json_rpc_response = JSONRPC20Response.from_json(sse.data)
                     if json_rpc_response.error:
                         raise A2AClientJSONRPCError(json_rpc_response.error)

src/a2a/client/transports/rest.py

@@ -383,6 +383,8 @@ async def subscribe(
         ) as event_source:
             try:
                 async for sse in event_source.aiter_sse():
+                    if not sse.data:
+                        continue
                     event: StreamResponse = Parse(sse.data, StreamResponse())
                     yield event
             except SSEError as e:

tests/client/test_errors.py

@@ -170,11 +170,9 @@ class TestA2AClientJSONRPCErrorRepr:
 
     def test_repr(self) -> None:
         """Test that __repr__ shows the JSON-RPC error object."""
-        response = JSONRPC20Response(
-            _id='test-1',
-            error={'code': -32601, 'message': 'Method not found', 'data': None},
+        error = A2AClientJSONRPCError(
+            {'code': -32601, 'message': 'Method not found', 'data': None}
         )
-        error = A2AClientJSONRPCError(response.error)
         assert (
             repr(error)
             == "A2AClientJSONRPCError(\"JSON-RPC Error {'code': -32601, 'message': 'Method not found', 'data': None}\")"