gave each operation a uuid

Author: daniel-sanche

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

@@ -92,7 +92,8 @@ def register_operation(self, operation):
         operation.handlers.append(self)
 
     def on_operation_complete(self, op):
-        del self.operation_map[op.uuid]
+        if op.uuid in self.operation_map:
+            del self.operation_map[op.uuid]
 
     def on_operation_cancelled(self, op):
         self.on_operation_complete(op)

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

@@ -143,7 +143,7 @@ class ActiveOperationMetric:
     """
 
     op_type: OperationType
-    uuid: str = str(uuid.uuid4())
+    uuid: str = field(default_factory=lambda: str(uuid.uuid4()))
     backoff_generator: TrackedBackoffGenerator | None = None
     # keep monotonic timestamps for active operations
     start_time_ns: int = field(default_factory=time.monotonic_ns)