fixed init issues

Author: daniel-sanche

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

@@ -215,8 +215,8 @@ def __init__(
                 project = _DEFAULT_BIGTABLE_EMULATOR_CLIENT
         # create a metrics exporter using the same client configuration
         self._gcp_metrics_exporter = BigtableMetricsExporter(
+            project_id=project,
             credentials=credentials,
-            project=project,
             client_options=client_options,
         )
         self._metrics_interceptor = MetricInterceptorType()
@@ -981,7 +981,6 @@ def __init__(
             handlers=[
                 GoogleCloudMetricsHandler(
                     exporter=client._gcp_metrics_exporter,
-                    project_id=self.client.project,
                     instance_id=instance_id,
                     table_id=table_id,
                     app_profile_id=app_profile_id
@@ -1702,6 +1701,8 @@ async def close(self):
         """
         Called to close the Table instance and release any resources held by it.
         """
+        for handler in self._metrics.handlers:
+            handler.close()
         if self._register_instance_future:
             self._register_instance_future.cancel()
         await self.client._remove_instance_registration(self.instance_id, self)

google/cloud/bigtable/data/_metrics/handlers/_base.py

@@ -33,3 +33,6 @@ def on_attempt_complete(
         self, attempt: CompletedAttemptMetric, op: ActiveOperationMetric
     ) -> None:
         pass
+
+    def close(self):
+        pass

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

@@ -112,9 +112,12 @@ def __init__(self, exporter, *args, export_interval=60, **kwargs):
             exporter, export_interval_millis=export_interval * 1000
         )
         # use private meter provider to store instruments and views
-        meter_provider = MeterProvider(metric_readers=[gcp_reader], views=VIEW_LIST)
-        otel = _OpenTelemetryInstruments(meter_provider=meter_provider)
-        super().__init__(*args, instruments=otel, project_id=exporter.roject_id, **kwargs)
+        self.meter_provider = MeterProvider(metric_readers=[gcp_reader], views=VIEW_LIST)
+        otel = _OpenTelemetryInstruments(meter_provider=self.meter_provider)
+        super().__init__(*args, instruments=otel, project_id=exporter.project_id, **kwargs)
+
+    def close(self):
+        self.meter_provider.shutdown()
 
 
 class BigtableMetricsExporter(MetricExporter):
@@ -131,11 +134,11 @@ class BigtableMetricsExporter(MetricExporter):
       - project_id: GCP project id to associate metrics with
     """
 
-    def __init__(self, *client_args, **client_kwargs):
+    def __init__(self, project_id: str, *client_args, **client_kwargs):
         super().__init__()
         self.client = MetricServiceClient(*client_args, **client_kwargs)
         self.prefix = "bigtable.googleapis.com/internal/client"
-        self.project_id = self.client.project
+        self.project_id = project_id
         self.project_name = self.client.common_project_path(self.project_id)
 
     def export(