We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 07e00ba commit 77a7f95Copy full SHA for 77a7f95
1 file changed
sdks/python/apache_beam/io/gcp/bigtableio.py
@@ -55,7 +55,6 @@
55
FLUSH_COUNT = 1000
56
MAX_ROW_BYTES = 5242880 # 5MB
57
58
-
59
except ImportError:
60
_LOGGER.warning(
61
'ImportError: from google.cloud.bigtable import Client', exc_info=True)
@@ -134,7 +133,7 @@ def start_bundle(self):
134
133
self.beam_options['instance_id'],
135
self.beam_options['table_id'])
136
self.batcher = MutationsBatcher(
137
- self.table, batch_completed_callback=self.write_mutate_metrics)
+ self.table, batch_completed_callback=self.write_mutate_metrics)
138
139
def process(self, row):
140
self.written.inc()
0 commit comments