test

chromadb/api/segment.py

@@ -111,8 +111,7 @@ def __init__(self, system: System):
     @override
     def heartbeat(self) -> int:
         return int(time.time_ns())
-
-    @trace_method("SegmentAPI.create_database", OpenTelemetryGranularity.OPERATION)
+
     @override
     def create_database(self, name: str, tenant: str = DEFAULT_TENANT) -> None:
         if len(name) < 3:

chromadb/db/impl/grpc/client.py

@@ -58,8 +58,7 @@ def __init__(self, system: System):
         self._coordinator_url = system.settings.require("chroma_coordinator_host")
         # TODO: break out coordinator_port into a separate setting?
         self._coordinator_port = system.settings.require("chroma_server_grpc_port")
-        self._opentelemetry_client = system.require(OpenTelemetryClient)
-        super().__init__(system)
+        return super().__init__(system)
 
     @overrides
     def start(self) -> None:

chromadb/telemetry/opentelemetry/grpc.py

@@ -32,8 +32,6 @@ class OtelInterceptor(
     grpc.StreamStreamClientInterceptor
 ):
     def _intercept_call(self, continuation, client_call_details, request_or_iterator):
-        if tracer is None:
-            return continuation(client_call_details, request_or_iterator)
         with tracer.start_as_current_span(f"RPC {client_call_details.method}", kind=SpanKind.CLIENT) as span:
             # Prepare metadata for propagation
             metadata = client_call_details.metadata[:] if client_call_details.metadata else []