diff --git a/google/cloud/bigtable/batcher.py b/google/cloud/bigtable/batcher.py index 82c0bdb91..f1c957537 100644 --- a/google/cloud/bigtable/batcher.py +++ b/google/cloud/bigtable/batcher.py @@ -132,7 +132,7 @@ def control_flow(self, batch_info): with self._lock: self.inflight_mutations += batch_info.mutations_count self.inflight_size += batch_info.mutations_size - self.set_flow_control_status() + self.set_flow_control_status() def wait(self): """ @@ -159,7 +159,7 @@ def release(self, batch_info): with self._lock: self.inflight_mutations -= batch_info.mutations_count self.inflight_size -= batch_info.mutations_size - self.set_flow_control_status() + self.set_flow_control_status() class MutationsBatcher(object):