Skip to content

Commit 77a7f95

Browse files
committed
fix format
1 parent 07e00ba commit 77a7f95

1 file changed

Lines changed: 1 addition & 2 deletions

File tree

sdks/python/apache_beam/io/gcp/bigtableio.py

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -55,7 +55,6 @@
5555
FLUSH_COUNT = 1000
5656
MAX_ROW_BYTES = 5242880 # 5MB
5757

58-
5958
except ImportError:
6059
_LOGGER.warning(
6160
'ImportError: from google.cloud.bigtable import Client', exc_info=True)
@@ -134,7 +133,7 @@ def start_bundle(self):
134133
self.beam_options['instance_id'],
135134
self.beam_options['table_id'])
136135
self.batcher = MutationsBatcher(
137-
self.table, batch_completed_callback=self.write_mutate_metrics)
136+
self.table, batch_completed_callback=self.write_mutate_metrics)
138137

139138
def process(self, row):
140139
self.written.inc()

0 commit comments

Comments
 (0)