Wait until job is completed (feast-dev#1123)

terryyylim · web-flow · commit a357b91fceec · 2020-11-02T18:04:09.000+08:00
Signed-off-by: Terence &lt;terencelimxp@gmail.com&gt;
diff --git a/sdk/python/feast/loaders/ingest.py b/sdk/python/feast/loaders/ingest.py
@@ -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()`