Skip to content

Commit 3b1dca0

Browse files
committed
docstring
1 parent d8d6ac1 commit 3b1dca0

2 files changed

Lines changed: 5 additions & 4 deletions

File tree

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

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -326,7 +326,7 @@ def query_foundry_sql(
326326
arrow_compression_codec: ArrowCompressionCodec = ...,
327327
timeout: int = ...,
328328
experimental_use_trino: bool = ...,
329-
) -> pd.core.frame.DataFrame: ...
329+
) -> pd.DataFrame: ...
330330

331331
@overload
332332
def query_foundry_sql(
@@ -374,7 +374,7 @@ def query_foundry_sql(
374374
arrow_compression_codec: ArrowCompressionCodec = ...,
375375
timeout: int = ...,
376376
experimental_use_trino: bool = ...,
377-
) -> pd.core.frame.DataFrame | pl.DataFrame | pa.Table | pyspark.sql.DataFrame: ...
377+
) -> pd.DataFrame | pl.DataFrame | pa.Table | pyspark.sql.DataFrame: ...
378378

379379
def query_foundry_sql(
380380
self,
@@ -385,7 +385,7 @@ def query_foundry_sql(
385385
arrow_compression_codec: ArrowCompressionCodec = "NONE",
386386
timeout: int = 600,
387387
experimental_use_trino: bool = False,
388-
) -> pd.core.frame.DataFrame | pl.DataFrame | pa.Table | pyspark.sql.DataFrame:
388+
) -> pd.DataFrame | pl.DataFrame | pa.Table | pyspark.sql.DataFrame:
389389
"""Queries the Foundry SQL server using the V2 API.
390390
391391
Uses Arrow IPC to communicate with the Foundry SQL Server Endpoint.
@@ -510,7 +510,7 @@ def _extract_ticket(self, response_json: dict[str, Any]) -> dict[str, Any]:
510510
response_json: Success response JSON from status API
511511
512512
Returns:
513-
List of tickets for fetching results
513+
Ticket dict with id, tickets list, and type. Example: {"id": 0, "tickets": [...], "type": "furnace"}
514514
515515
Raises:
516516
KeyError: If the response JSON doesn't contain the expected structure

tests/integration/clients/test_foundry_sql_server.py

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -168,6 +168,7 @@ def test_v2_disable_arrow_compression():
168168
"""Test V2 client with arrow compression disabled."""
169169
result = TEST_SINGLETON.ctx.foundry_sql_server_v2.query_foundry_sql(
170170
query=f"SELECT * FROM `{TEST_SINGLETON.iris_new.rid}` LIMIT 5",
171+
arrow_compression_codec="NONE",
171172
)
172173
assert result.shape[0] == 5
173174

0 commit comments

Comments
 (0)