Skip to content
This repository was archived by the owner on Mar 6, 2026. It is now read-only.

Docs: update query_to_arrow.py to use query_and_wait API #1776

Merged
kiraksi merged 6 commits into from
Jan 25, 2024
Merged

Docs: update query_to_arrow.py to use query_and_wait API #1776

Changes from all commits
Commits
Show all changes
6 commits
Select commit Hold shift + click to select a range
a0607be
docs: update sample for query_to_arrow to use query_and_wait API
Jan 12, 2024
3349dae
Merge branch 'main' into salem_query_to_arrow_updates
kiraksi Jan 18, 2024
b68fef1
Merge branch 'main' into salem_query_to_arrow_updates
chalmerlowe Jan 22, 2024
b2016e3
Merge branch 'main' into salem_query_to_arrow_updates
kiraksi Jan 25, 2024
f656dde
Merge branch 'main' into salem_query_to_arrow_updates
kiraksi Jan 25, 2024
f0df7c8
Merge branch 'main' into salem_query_to_arrow_updates
kiraksi Jan 25, 2024
File filter

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
4 changes: 2 additions & 2 deletions samples/query_to_arrow.py
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -44,8 +44,8 @@ def query_to_arrow() -> "pyarrow.Table":
FROM races r
CROSS JOIN UNNEST(r.participants) as participant;
"""
query_job = client.query(sql)
arrow_table = query_job.to_arrow() # Make an API request.
results = client.query_and_wait(sql)
arrow_table = results.to_arrow() # Make an API request.

print(
"Downloaded {} rows, {} columns.".format(
Expand Down