You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by pa...@apache.org on 2019/10/23 15:47:43 UTC
[beam] branch master updated: Fixing BQ write transform
This is an automated email from the ASF dual-hosted git repository.
pabloem pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git
The following commit(s) were added to refs/heads/master by this push:
new 52c45a7 Fixing BQ write transform
new eb40876 Merge pull request #9856 from pabloem/fixbqwr
52c45a7 is described below
commit 52c45a7957b0161b855d264f7add1ad004240fe8
Author: pabloem <pa...@apache.org>
AuthorDate: Tue Oct 22 14:52:01 2019 -0700
Fixing BQ write transform
---
sdks/python/apache_beam/io/gcp/bigquery_file_loads.py | 2 ++
1 file changed, 2 insertions(+)
diff --git a/sdks/python/apache_beam/io/gcp/bigquery_file_loads.py b/sdks/python/apache_beam/io/gcp/bigquery_file_loads.py
index e74a39b..cb285ea 100644
--- a/sdks/python/apache_beam/io/gcp/bigquery_file_loads.py
+++ b/sdks/python/apache_beam/io/gcp/bigquery_file_loads.py
@@ -527,6 +527,8 @@ class WaitForBQJobs(beam.DoFn):
return WaitForBQJobs.FAILED
elif job.status.state == 'DONE':
continue
+ else:
+ return WaitForBQJobs.WAITING
return WaitForBQJobs.ALL_DONE