From c778ec59eca43c2c426b7a7ef3c88fe43afed8d2 Mon Sep 17 00:00:00 2001 From: Terence Date: Mon, 2 Nov 2020 16:12:48 +0800 Subject: [PATCH] Wait until job is completed Signed-off-by: Terence --- sdk/python/feast/loaders/ingest.py | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/sdk/python/feast/loaders/ingest.py b/sdk/python/feast/loaders/ingest.py index 581958f5c0..dc87d5b32e 100644 --- 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()