Skip to content

Commit ddb3246

Browse files
Reverting AQUA client changes
1 parent 659e675 commit ddb3246

File tree

1 file changed

+4
-2
lines changed

1 file changed

+4
-2
lines changed

ads/aqua/client/client.py

Lines changed: 4 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -314,9 +314,11 @@ def _parse_streaming_line(
314314
try:
315315
json_line = json.loads(line)
316316
logger.debug(f"Parsed JSON line: {json_line}")
317-
except json.JSONDecodeError:
317+
except json.JSONDecodeError as e:
318318
logger.debug(f"Error decoding JSON from line: {line}")
319-
return None
319+
raise json.JSONDecodeError(
320+
f"Error decoding JSON from line: {e!s}", e.doc, e.pos
321+
) from e
320322

321323
if json_line.get("object") == "error":
322324
# Raise an error for error objects in the stream

0 commit comments

Comments
 (0)