[Bug]: SSE client splits data lines on U+2028, U+2029 and U+0085, so streamed events fail to parse

オープン
  • 何か問題がありますか？
#1,432 コメント 0 件 リアクション 0 件 担当者 2 名 GitHub で見る

メンテナーはふだん 2 日以内に返信

@rohityan がすでに取り組んでいます。

2026年11月7日 から。

  • #1433 @devinhuang2001 による — オープン

評価

この issue はまだ評価されていません。

説明

What happened?

parse_sse_stream in src/a2a/client/transports/http_helpers.py reads the stream with response.aiter_lines() (line 78). httpx's line decoder follows str.splitlines(), so it also ends a line at U+2028 (LINE SEPARATOR), U+2029 (PARAGRAPH SEPARATOR) and U+0085 (NEL). SSE line ends are only CR, LF and CRLF, and the docstring on line 73 says the parser conforms to the SSE spec.

The server writes these three characters raw: json_utils.dumps uses ensure_ascii=False (src/a2a/utils/json_utils.py:19). sse-starlette frames on CR/LF only, so it sends one data: line. The client splits that line into several. json.loads fails on the first piece, and the stream ends with A2AClientError('Invalid JSON-RPC response in SSE stream').

Any string field in a streamed event can hold these characters, for example message text, artifacts or status messages that quote a document. Resubscribing sends the same task snapshot, so that task stays unreadable over streaming. Non-streaming GetTask is not affected. The same parser is used by the JSON-RPC and REST transports and by the v0.3 compat transports.

This looks like a regression from #1132, which removed httpx-sse. httpx-sse 0.4.3 split SSE lines on CR/LF only (_splitlines_sse).

Repro (library level, using the versions pinned in uv.lock: sse-starlette 3.4.4, httpx 0.28.1)

import asyncio, json
import httpx
from sse_starlette.sse import ServerSentEvent

async def main():
    data = json.dumps({"text": "before
after"}, ensure_ascii=False)
    frame = ServerSentEvent(data=data).encode()
    print(frame.count(b"data:"))  # 1: the server sends one data line
    async def body():
        yield frame
    resp = httpx.Response(200, content=body())
    lines = [l async for l in resp.aiter_lines()]
    print(len(lines))             # 3: the client sees the data line split in two
    json.loads(lines[0][len("data: "):])

asyncio.run(main())

Expected: one data: line that parses as JSON. Observed: JSONDecodeError.

Possible fixes:

  • Split SSE lines on CR, LF and CRLF only, with a small line decoder over aiter_text().
  • Also, or instead: escape U+2028, U+2029 and U+0085 in json_utils.dumps.

Related: #1213, the end-of-stream flush in the same parser.

No existing tests cover these characters in SSE data.

Relevant log output
json.decoder.JSONDecodeError: Unterminated string starting at: line 1 column 10 (char 9)
Code of Conduct
  • I agree to follow this project's Code of Conduct

Drafted with Claude Code. I reviewed the code paths and ran the repro.

主要言語
Python
スター
2.2k
フォーク
532
平均マージ
3日 2時間
マージ済み PR（30日）
46

環境構築

はじめの一歩

  1. issue を最後まで読み、次にプロジェクトのコントリビューションガイドを読みます。
  2. 着手することを issue にコメントします — 二人が同じ作業をするのを防げます。
  3. リポジトリをフォークし、ブランチを切って変更します。
  4. issue 番号を参照したプルリクエストを送ります。

a2aproject/a2a-python のほかの issue

a2aproject/a2a-python の issue をすべて見る

似ている issue

Python の issue をもっと見る

新しい issue をメールで受け取る

初心者向けの GitHub issue を短くまとめたダイジェスト。