fixed errors

Author: daniel-sanche

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

@@ -1025,7 +1025,7 @@ async def read_rows_stream(
             operation_timeout=operation_timeout,
             attempt_timeout=attempt_timeout,
             metric=self._metrics.create_operation(
-                OperationType.READ_ROWS, streaming=True
+                OperationType.READ_ROWS, is_streaming=True
             ),
             retryable_exceptions=retryable_excs,
         )
@@ -1133,13 +1133,13 @@ async def read_row(
             operation_timeout=operation_timeout,
             attempt_timeout=attempt_timeout,
             metric=self._metrics.create_operation(
-                OperationType.READ_ROWS, streaming=False
+                OperationType.READ_ROWS, is_streaming=False
             ),
             retryable_exceptions=retryable_excs,
         )
         results_generator = row_merger.start_operation()
         try:
-            return results_generator.__anext__()
+            return await results_generator.__anext__()
         except StopAsyncIteration:
             return None
 

google/cloud/bigtable/data/_metrics/data_model.py

@@ -28,11 +28,11 @@
 
 import google.cloud.bigtable.data.exceptions as bt_exceptions
 from google.cloud.bigtable_v2.types.response_params import ResponseParams
+from google.cloud.bigtable.data._helpers import TrackedBackoffGenerator
 from google.protobuf.message import DecodeError
 
 if TYPE_CHECKING:
     from google.cloud.bigtable.data._metrics.handlers._base import MetricsHandler
-    from google.cloud.bigtable.data._helpers import TrackedBackoffGenerator
 
 
 LOGGER = logging.getLogger(__name__)

google/cloud/bigtable/data/_sync_autogen/client.py

@@ -810,7 +810,7 @@ def read_rows_stream(
             operation_timeout=operation_timeout,
             attempt_timeout=attempt_timeout,
             metric=self._metrics.create_operation(
-                OperationType.READ_ROWS, streaming=True
+                OperationType.READ_ROWS, is_streaming=True
             ),
             retryable_exceptions=retryable_excs,
         )
@@ -910,7 +910,7 @@ def read_row(
             operation_timeout=operation_timeout,
             attempt_timeout=attempt_timeout,
             metric=self._metrics.create_operation(
-                OperationType.READ_ROWS, streaming=False
+                OperationType.READ_ROWS, is_streaming=False
             ),
             retryable_exceptions=retryable_excs,
         )