Reformat bigquery_tools.py (#26622)

dopieralad · dopieralad · commit 77c2b02ac04f · 2023-05-30T06:40:27.000+02:00
diff --git a/sdks/python/apache_beam/io/gcp/bigquery_tools.py b/sdks/python/apache_beam/io/gcp/bigquery_tools.py
@@ -1346,17 +1346,18 @@ def convert_row_to_dict(self, row, schema):
 
   @staticmethod
   def from_pipeline_options(pipeline_options: PipelineOptions):
-    return BigQueryWrapper(client=BigQueryWrapper._bigquery_client(pipeline_options))
+    return BigQueryWrapper(
+        client=BigQueryWrapper._bigquery_client(pipeline_options))
 
   @staticmethod
   def _bigquery_client(pipeline_options: PipelineOptions):
     return bigquery.BigqueryV2(
-          http=get_new_http(),
-          credentials=auth.get_service_credentials(pipeline_options),
-          response_encoding='utf8',
-          additional_http_headers={
-              "user-agent": "apache-beam-%s" % apache_beam.__version__
-          })
+        http=get_new_http(),
+        credentials=auth.get_service_credentials(pipeline_options),
+        response_encoding='utf8',
+        additional_http_headers={
+            "user-agent": "apache-beam-%s" % apache_beam.__version__
+        })
 
 
 class RowAsDictJsonCoder(coders.Coder):
