From 77a7f95f34e4aec6b81f184260720204983b0e5d Mon Sep 17 00:00:00 2001 From: Mattie Fu Date: Fri, 9 Jun 2023 10:57:58 -0400 Subject: [PATCH] fix format --- sdks/python/apache_beam/io/gcp/bigtableio.py | 3 +-- 1 file changed, 1 insertion(+), 2 deletions(-) diff --git a/sdks/python/apache_beam/io/gcp/bigtableio.py b/sdks/python/apache_beam/io/gcp/bigtableio.py index 5169ef0a5c93..3f045ee26f86 100644 --- a/sdks/python/apache_beam/io/gcp/bigtableio.py +++ b/sdks/python/apache_beam/io/gcp/bigtableio.py @@ -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) @@ -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()