[beam] branch master updated: Adding display data to BQ File Loads transform

[pa...@apache.org]

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 eb58694  Adding display data to BQ File Loads transform
     new 7dcbdf1  Merge pull request #13249 from Adding display data to BQ File Loads transform
eb58694 is described below

commit eb586949dca35b984ccbefdb581fa4428f87fd45
Author: Pablo Estrada <pa...@apache.org>
AuthorDate: Tue Nov 3 12:29:48 2020 -0800

    Adding display data to BQ File Loads transform
---
 sdks/python/apache_beam/io/gcp/bigquery_file_loads.py | 7 ++++---
 1 file changed, 4 insertions(+), 3 deletions(-)

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 09eb124..0342b4c 100644
--- a/sdks/python/apache_beam/io/gcp/bigquery_file_loads.py
+++ b/sdks/python/apache_beam/io/gcp/bigquery_file_loads.py
@@ -447,10 +447,11 @@ class TriggerLoadJobs(beam.DoFn):
     result = {
         'create_disposition': str(self.create_disposition),
         'write_disposition': str(self.write_disposition),
+        'additional_bq_params': str(self.additional_bq_parameters),
+        'schema': str(self.schema),
+        'launchesBigQueryJobs': DisplayDataItem(
+            True, label="This Dataflow job launches bigquery jobs.")
     }
-    result['schema'] = str(self.schema)
-    result['launchesBigQueryJobs'] = DisplayDataItem(
-        True, label="This Dataflow job launches bigquery jobs.")
     return result
 
   def start_bundle(self):