Skip to content

Commit 46a4edb

Browse files
committed
fix decode_content
1 parent e7e37c5 commit 46a4edb

1 file changed

Lines changed: 2 additions & 0 deletions

File tree

libs/foundry-dev-tools/src/foundry_dev_tools/clients/foundry_sql_server.py

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -434,6 +434,7 @@ def _extract_tickets(self, response_json: dict[str, Any]) -> list[str]:
434434
"""
435435
if response_json.get("type") != "success":
436436
msg = f"Expected success response, got: {response_json.get('type')}"
437+
437438
raise ValueError(msg)
438439

439440
chunks = response_json["success"]["result"]["interactive"]["chunks"]
@@ -452,6 +453,7 @@ def read_stream_results_arrow(self, tickets: list[str]) -> pa.ipc.RecordBatchStr
452453
from foundry_dev_tools._optional.pyarrow import pa
453454

454455
response = self._api_stream_ticket(tickets)
456+
response.raw.decode_content = True
455457

456458
return pa.ipc.RecordBatchStreamReader(response.raw)
457459

0 commit comments

Comments
 (0)