This repository was archived by the owner on Apr 1, 2026. It is now read-only.
File tree Expand file tree Collapse file tree
google/cloud/bigtable/data Expand file tree Collapse file tree Original file line number Diff line number Diff line change 2222import google .cloud .bigtable .data .exceptions as bt_exceptions
2323from google .cloud .bigtable .data ._helpers import _attempt_timeout_generator
2424from google .cloud .bigtable .data ._helpers import _retry_exception_factory
25- from google .cloud .bigtable .data ._helpers import TrackedBackoffGenerator
2625
2726# mutate_rows requests are limited to this number of mutations
2827from google .cloud .bigtable .data .mutations import _MUTATE_ROWS_REQUEST_MUTATION_LIMIT
Original file line number Diff line number Diff line change 3131from google .cloud .bigtable .data .exceptions import _ResetRow
3232from google .cloud .bigtable .data ._helpers import _attempt_timeout_generator
3333from google .cloud .bigtable .data ._helpers import _retry_exception_factory
34- from google .cloud .bigtable .data ._helpers import TrackedBackoffGenerator
3534
3635from google .api_core import retry as retries
3736
Original file line number Diff line number Diff line change 7878from google .cloud .bigtable .data ._helpers import _get_retryable_errors
7979from google .cloud .bigtable .data ._helpers import _get_timeouts
8080from google .cloud .bigtable .data ._helpers import _attempt_timeout_generator
81- from google .cloud .bigtable .data ._helpers import TrackedBackoffGenerator
8281from google .cloud .bigtable .data .mutations import Mutation , RowMutationEntry
8382
8483from google .cloud .bigtable .data .read_modify_write_rules import ReadModifyWriteRule
Original file line number Diff line number Diff line change @@ -146,7 +146,9 @@ class ActiveOperationMetric:
146146 uuid : str = field (default_factory = lambda : str (uuid .uuid4 ()))
147147 # create a default backoff generator, initialized with standard default backoff values
148148 backoff_generator : TrackedBackoffGenerator = field (
149- default_factory = lambda : TrackedBackoffGenerator (initial = 0.01 , maximum = 60 , multiplier = 2 )
149+ default_factory = lambda : TrackedBackoffGenerator (
150+ initial = 0.01 , maximum = 60 , multiplier = 2
151+ )
150152 )
151153 # keep monotonic timestamps for active operations
152154 start_time_ns : int = field (default_factory = time .monotonic_ns )
@@ -204,9 +206,7 @@ def start_attempt(self) -> ActiveAttemptMetric:
204206 try :
205207 # find backoff value before this attempt
206208 prev_attempt_idx = len (self .completed_attempts ) - 1
207- backoff = self .backoff_generator .get_attempt_backoff (
208- prev_attempt_idx
209- )
209+ backoff = self .backoff_generator .get_attempt_backoff (prev_attempt_idx )
210210 # generator will return the backoff time in seconds, so convert to nanoseconds
211211 backoff_ns = int (backoff * 1e9 )
212212 except IndexError :
You can’t perform that action at this time.
0 commit comments