Skip to content

Commit

Permalink
use temp table for entity df table
Browse files Browse the repository at this point in the history
Signed-off-by: Achal Shah <achals@gmail.com>
  • Loading branch information
achals committed Jul 7, 2022
1 parent 7fbc119 commit d3e6533
Showing 1 changed file with 1 addition and 1 deletion.
2 changes: 1 addition & 1 deletion sdk/python/feast/infra/offline_stores/bigquery.py
Original file line number Diff line number Diff line change
Expand Up @@ -603,7 +603,7 @@ def _upload_entity_df(
"""Uploads a Pandas entity dataframe into a BigQuery table and returns the resulting table"""

if isinstance(entity_df, str):
job = client.query(f"CREATE TABLE {table_name} AS ({entity_df})")
job = client.query(f"CREATE TEMP TABLE {table_name} AS ({entity_df})")

elif isinstance(entity_df, pd.DataFrame):
# Drop the index so that we don't have unnecessary columns
Expand Down

0 comments on commit d3e6533

Please sign in to comment.