@@ -959,8 +959,8 @@ def _read_pandas_load_job(
959
959
)
960
960
table_expression = self .ibis_client .table ( # type: ignore
961
961
load_table_destination .table_id ,
962
- # TODO: use "dataset_id" as the " schema"
963
- database = f" { load_table_destination .project } . { load_table_destination . dataset_id } " ,
962
+ schema = load_table_destination . dataset_id ,
963
+ database = load_table_destination .project ,
964
964
)
965
965
966
966
# b/297590178 Potentially a bug in bqclient.load_table_from_dataframe(), that only when the DF is empty, the index columns disappear in table_expression.
@@ -1542,7 +1542,9 @@ def _cache_with_cluster_cols(
1542
1542
ibis_expr , cluster_cols = cluster_cols , api_name = "cached"
1543
1543
)
1544
1544
table_expression = self .ibis_client .table (
1545
- f"{ tmp_table .project } .{ tmp_table .dataset_id } .{ tmp_table .table_id } "
1545
+ tmp_table .table_id ,
1546
+ schema = tmp_table .dataset_id ,
1547
+ database = tmp_table .project ,
1546
1548
)
1547
1549
new_columns = [table_expression [column ] for column in compiled_value .column_ids ]
1548
1550
new_hidden_columns = [
@@ -1571,7 +1573,9 @@ def _cache_with_offsets(self, array_value: core.ArrayValue) -> core.ArrayValue:
1571
1573
ibis_expr , cluster_cols = ["bigframes_offsets" ], api_name = "cached"
1572
1574
)
1573
1575
table_expression = self .ibis_client .table (
1574
- f"{ tmp_table .project } .{ tmp_table .dataset_id } .{ tmp_table .table_id } "
1576
+ tmp_table .table_id ,
1577
+ schema = tmp_table .dataset_id ,
1578
+ database = tmp_table .project ,
1575
1579
)
1576
1580
new_columns = [table_expression [column ] for column in compiled_value .column_ids ]
1577
1581
new_hidden_columns = [table_expression ["bigframes_offsets" ]]
0 commit comments