Skip to content

Commit

Permalink
fix format
Browse files Browse the repository at this point in the history
  • Loading branch information
mutianf committed Jun 9, 2023
1 parent 07e00ba commit 77a7f95
Showing 1 changed file with 1 addition and 2 deletions.
3 changes: 1 addition & 2 deletions sdks/python/apache_beam/io/gcp/bigtableio.py
Original file line number Diff line number Diff line change
Expand Up @@ -55,7 +55,6 @@
FLUSH_COUNT = 1000
MAX_ROW_BYTES = 5242880 # 5MB


except ImportError:
_LOGGER.warning(
'ImportError: from google.cloud.bigtable import Client', exc_info=True)
Expand Down Expand Up @@ -134,7 +133,7 @@ def start_bundle(self):
self.beam_options['instance_id'],
self.beam_options['table_id'])
self.batcher = MutationsBatcher(
self.table, batch_completed_callback=self.write_mutate_metrics)
self.table, batch_completed_callback=self.write_mutate_metrics)

def process(self, row):
self.written.inc()
Expand Down

0 comments on commit 77a7f95

Please sign in to comment.