Skip to content
This repository was archived by the owner on Apr 1, 2026. It is now read-only.

Commit eb3aae1

Browse files
committed
fixed blacken
1 parent f2528ae commit eb3aae1

1 file changed

Lines changed: 4 additions & 3 deletions

File tree

google/cloud/bigtable/data/_async/_read_rows.py

Lines changed: 4 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -117,13 +117,14 @@ def start_operation(self) -> AsyncGenerator[Row, None]:
117117
# Metrics:
118118
# track attempt failures using build_wrapped_fn_handlers() for raised exceptions
119119
# and operation timeouts
120-
metric_predicate, metric_excs = self._operation_metrics.build_wrapped_fn_handlers(self._predicate)
120+
metric_fns = self._operation_metrics.build_wrapped_fn_handlers(self._predicate)
121+
metric_predicate, metric_exc_factory = metric_fns
121122
return retries.retry_target_stream_async(
122123
self._read_rows_attempt,
123-
metric_predicate,
124+
metric_fns[0],
124125
sleep_generator,
125126
self.operation_timeout,
126-
exception_factory=metric_excs,
127+
exception_factory=metric_fns[1],
127128
)
128129

129130
def _read_rows_attempt(self) -> AsyncGenerator[Row, None]:

0 commit comments

Comments
 (0)