feast-dev
diff --git a/‎sdk/python/feast/loaders/ingest.py‎
Lines changed: 3 additions & 1 deletion b/‎sdk/python/feast/loaders/ingest.py‎
Lines changed: 3 additions & 1 deletion
@@ -230,4 +230,6 @@ def _upload_to_bq_source(
     )
     job_config.time_partitioning = time_partitioning_obj
     with open(dest_path, "rb") as source_file:
-        bq_client.load_table_from_file(source_file, table, job_config=job_config)
+        bq_client.load_table_from_file(
+            source_file, table, job_config=job_config
+        ).result()
Original file line number	Diff line number	Diff line change
`@@ -230,4 +230,6 @@ def _upload_to_bq_source(`
`230`	`230`	`)`
`231`	`231`	`job_config.time_partitioning = time_partitioning_obj`
`232`	`232`	`with open(dest_path, "rb") as source_file:`
`233`		`- bq_client.load_table_from_file(source_file, table, job_config=job_config)`
	`233`	`+ bq_client.load_table_from_file(`
	`234`	`+ source_file, table, job_config=job_config`
	`235`	`+ ).result()`