diff --git a/sdks/python/apache_beam/io/gcp/gcsio.py b/sdks/python/apache_beam/io/gcp/gcsio.py index a64db5b36401..6e615e25906c 100644 --- a/sdks/python/apache_beam/io/gcp/gcsio.py +++ b/sdks/python/apache_beam/io/gcp/gcsio.py @@ -147,8 +147,10 @@ def __init__(self, storage_client=None, pipeline_options=None): storage_client = create_storage_client(pipeline_options) google_cloud_options = pipeline_options.view_as(GoogleCloudOptions) - self.enable_read_bucket_metric = getattr(google_cloud_options, 'enable_bucket_read_metric_counter', False) - self.enable_write_bucket_metric = getattr(google_cloud_options, 'enable_bucket_write_metric_counter', False) + self.enable_read_bucket_metric = getattr( + google_cloud_options, 'enable_bucket_read_metric_counter', False) + self.enable_write_bucket_metric = getattr( + google_cloud_options, 'enable_bucket_write_metric_counter', False) self.client = storage_client self._rewrite_cb = None