Skip to content

Commit 68ea084

Browse files
committed
bug: fix BQ client schema access
1 parent 3559d43 commit 68ea084

1 file changed

Lines changed: 3 additions & 3 deletions

File tree

scripts/python/idc_index_data_manager.py

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -33,9 +33,9 @@ def execute_sql_query(
3333
"""
3434
with Path(file_path).open("r") as file:
3535
sql_query = file.read()
36-
query_job = self.client.query(sql_query)
37-
schema = query_job.schema # Get schema from BigQuery QueryJob
38-
index_df = query_job.to_dataframe()
36+
query_job_result = self.client.query(sql_query).result()
37+
schema = query_job_result.schema # Get schema from BigQuery QueryJob
38+
index_df = query_job_result.to_dataframe()
3939
if "StudyDate" in index_df.columns:
4040
index_df["StudyDate"] = index_df["StudyDate"].astype(str)
4141
output_basename = Path(file_path).name.split(".")[0]

0 commit comments

Comments
 (0)