Fix BigQuery schema update options formatting

Author: lalitium

sdks/python/apache_beam/io/gcp/bigquery.py

@@ -487,8 +487,8 @@ def chain_after(result):
 _SCHEMA_UPDATE_OPTIONS = 'schemaUpdateOptions'
 
 
-def _merge_schema_update_options(additional_bq_parameters,
-                                 schema_update_options):
+def _merge_schema_update_options(
+    additional_bq_parameters, schema_update_options):
   additional_bq_parameters = dict(additional_bq_parameters or {})
   if _SCHEMA_UPDATE_OPTIONS in additional_bq_parameters:
     raise ValueError(

sdks/python/apache_beam/io/gcp/bigquery_test.py

@@ -1038,14 +1038,13 @@ def test_schema_update_options_added_to_file_load_parameters(self):
         additional_bq_parameters=additional_bq_parameters,
         schema_update_options=schema_update_options)
 
-    self.assertEqual(
-        {
-            'timePartitioning': {
-                'type': 'DAY'
-            },
-            'schemaUpdateOptions': schema_update_options,
+    self.assertEqual({
+        'timePartitioning': {
+            'type': 'DAY'
         },
-        transform._additional_bq_parameters_for_file_loads())
+        'schemaUpdateOptions': schema_update_options,
+    },
+                     transform._additional_bq_parameters_for_file_loads())
     self.assertNotIn('schemaUpdateOptions', additional_bq_parameters)
 
   def test_schema_update_options_keeps_additional_bq_parameters_path(self):
@@ -1095,14 +1094,13 @@ def additional_bq_parameters(destination):
         schema_update_options=schema_update_options)
 
     additional_parameters = transform._additional_bq_parameters_for_file_loads()
-    self.assertEqual(
-        {
-            'clustering': {
-                'fields': ['columnA']
-            },
-            'schemaUpdateOptions': schema_update_options,
+    self.assertEqual({
+        'clustering': {
+            'fields': ['columnA']
         },
-        additional_parameters('project:dataset.table'))
+        'schemaUpdateOptions': schema_update_options,
+    },
+                     additional_parameters('project:dataset.table'))
 
   def test_schema_update_options_with_value_provider_parameters(self):
     schema_update_options = [
@@ -1118,14 +1116,13 @@ def test_schema_update_options_with_value_provider_parameters(self):
         schema_update_options=schema_update_options)
 
     additional_parameters = transform._additional_bq_parameters_for_file_loads()
-    self.assertEqual(
-        {
-            'timePartitioning': {
-                'type': 'DAY'
-            },
-            'schemaUpdateOptions': schema_update_options,
+    self.assertEqual({
+        'timePartitioning': {
+            'type': 'DAY'
         },
-        additional_parameters('project:dataset.table'))
+        'schemaUpdateOptions': schema_update_options,
+    },
+                     additional_parameters('project:dataset.table'))
 
   def test_schema_update_options_only_supported_for_file_loads(self):
     p = TestPipeline()