Wait until job is completed (#1123)

Signed-off-by: Terence <[email protected]>
feast-dev · Nov 2, 2020 · a357b91 · a357b91
1 parent 85eedf0
commit a357b91
Showing 1 changed file with 3 additions and 1 deletion.
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()