mirrors/claude-code-sdk-python
1
0
Fork 0
mirror of https://github.com/anthropics/claude-code-sdk-python.git synced 2025-07-07 14:45:00 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

Fixed Incomplete JSON Error

Browse source
This commit is contained in:
Alden Olivero 2025-06-17 21:02:58 +05:30 • committed by GitHub
parent 54bff2e85d
commit e8c53e199e
No known key found for this signature in database
GPG key ID: B5690EEEBB952194
1 changed files with 16 additions and 5 deletions
Download patch file Download diff file Expand all files Collapse all files

21
src/claude_code_sdk/_internal/transport/subprocess_cli.py
View file

@ -169,6 +169,7 @@ class SubprocessCLITransport(Transport):
raise CLIConnectionError("Not connected")
stderr_lines = []
json_buffer= ""
async def read_stderr() -> None:
"""Read stderr in background."""
@ -188,12 +189,22 @@ class SubprocessCLITransport(Transport):
if not line_str:
continue
try:
data = json.loads(line_str)
yield data
json_buffer += line_str
except json.JSONDecodeError as e:
if line_str.startswith("{") or line_str.startswith("["):
raise SDKJSONDecodeError(line_str, e) from e
if json_buffer.startswith("{") or json_buffer.startswith("["):
open_braces = json_buffer.count("{") - json_buffer.count("}")
open_brackets = json_buffer.count("[") - json_buffer.count("]")
if open_braces == 0 and open_brackets == 0:
print(f"WARNING: Malformed JSON detected: {json_buffer[:200]}...")
raise SDKJSONDecodeError(json_buffer, e) from e
print(f"Buffering incomplete JSON... (braces: {open_braces}, brackets: {open_brackets})")
json_buffer += "\n"
continue
else:
print(f"Skipping non-JSON line: {json_buffer[:200]}...")
json_buffer = ""
continue
except anyio.ClosedResourceError: