Skip to content

Commit

Permalink
Fix formatting issues
Browse files Browse the repository at this point in the history
  • Loading branch information
iht committed Aug 29, 2024
1 parent 8fe3386 commit b0caa79
Showing 1 changed file with 4 additions and 2 deletions.
6 changes: 4 additions & 2 deletions sdks/python/apache_beam/io/gcp/gcsio.py
Original file line number Diff line number Diff line change
Expand Up @@ -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
Expand Down

0 comments on commit b0caa79

Please sign in to comment.