fix mypy issues

Author: daniel-sanche

packages/google-cloud-bigtable/google/cloud/bigtable/data/_async/mutations_batcher.py

@@ -379,7 +379,7 @@ async def _flush_internal(self, new_entries: list[RowMutationEntry]):
         # flush new entries
         in_process_requests: list[CrossSync.Future[list[FailedMutationEntryError]]] = []
         async for batch, metric in self._flow_control.add_to_flow_with_metrics(
-            new_entries, self._target._metrics
+            new_entries, self._target.client._metrics
         ):
             batch_task = CrossSync.create_task(
                 self._execute_mutate_rows,

packages/google-cloud-bigtable/google/cloud/bigtable/data/_metrics/handlers/gcp_exporter.py

@@ -33,6 +33,7 @@
 from google.protobuf.timestamp_pb2 import Timestamp
 from opentelemetry.sdk.metrics import MeterProvider, view
 from opentelemetry.sdk.metrics.export import (
+    ExponentialHistogramDataPoint,
     HistogramDataPoint,
     MetricExporter,
     MetricExportResult,
@@ -262,7 +263,9 @@ def _batch_write(
             write_ind += max_batch_size
 
     @staticmethod
-    def _to_point(data_point: NumberDataPoint | HistogramDataPoint) -> Point:
+    def _to_point(
+        data_point: NumberDataPoint | HistogramDataPoint | ExponentialHistogramDataPoint,
+    ) -> Point:
         """
         Adapted from CloudMonitoringMetricsExporter
         https://github.com/GoogleCloudPlatform/opentelemetry-operations-python/blob/3668dfe7ce3b80dd01f42af72428de957b58b316/opentelemetry-exporter-gcp-monitoring/src/opentelemetry/exporter/cloud_monitoring/__init__.py#L82
@@ -281,11 +284,15 @@ def _to_point(data_point: NumberDataPoint | HistogramDataPoint) -> Point:
                     ),
                 )
             )
-        else:
+        elif isinstance(data_point, NumberDataPoint):
             if isinstance(data_point.value, int):
                 point_value = TypedValue(int64_value=data_point.value)
             else:
                 point_value = TypedValue(double_value=data_point.value)
+        else:
+            raise NotImplementedError(
+                f"Unsupported OTel data point type: {type(data_point)}"
+            )
         start_time = Timestamp()
         start_time.FromNanoseconds(data_point.start_time_unix_nano)
         end_time = Timestamp()

packages/google-cloud-bigtable/google/cloud/bigtable/data/_sync_autogen/mutations_batcher.py

@@ -329,7 +329,7 @@ def _flush_internal(self, new_entries: list[RowMutationEntry]):
             CrossSync._Sync_Impl.Future[list[FailedMutationEntryError]]
         ] = []
         for batch, metric in self._flow_control.add_to_flow_with_metrics(
-            new_entries, self._target._metrics
+            new_entries, self._target.client._metrics
         ):
             batch_task = CrossSync._Sync_Impl.create_task(
                 self._execute_mutate_rows,