diff --git a/instrumentation/opentelemetry-instrumentation-grpc/src/opentelemetry/instrumentation/grpc/_client.py b/instrumentation/opentelemetry-instrumentation-grpc/src/opentelemetry/instrumentation/grpc/_client.py index 3fc1fe7aa3..735d276097 100644 --- a/instrumentation/opentelemetry-instrumentation-grpc/src/opentelemetry/instrumentation/grpc/_client.py +++ b/instrumentation/opentelemetry-instrumentation-grpc/src/opentelemetry/instrumentation/grpc/_client.py @@ -123,7 +123,7 @@ def _start_guarded_span(self, *args, **kwargs): return _GuardedSpan(self._start_span(*args, **kwargs)) def intercept_unary(self, request, metadata, client_info, invoker): - if context.get_value( _SUPPRESS_INSTRUMENTATION_KEY): + if context.get_value(_SUPPRESS_INSTRUMENTATION_KEY): return invoker(request, metadata) if not metadata: @@ -193,7 +193,7 @@ def _intercept_server_stream( def intercept_stream( self, request_or_iterator, metadata, client_info, invoker ): - if context.get_value( _SUPPRESS_INSTRUMENTATION_KEY): + if context.get_value(_SUPPRESS_INSTRUMENTATION_KEY): return invoker(request_or_iterator, metadata) if client_info.is_server_stream: diff --git a/instrumentation/opentelemetry-instrumentation-grpc/tests/test_client_interceptor.py b/instrumentation/opentelemetry-instrumentation-grpc/tests/test_client_interceptor.py index 993d3f5971..a2a61f453f 100644 --- a/instrumentation/opentelemetry-instrumentation-grpc/tests/test_client_interceptor.py +++ b/instrumentation/opentelemetry-instrumentation-grpc/tests/test_client_interceptor.py @@ -179,7 +179,6 @@ def test_stream_unary(self): }, ) - def test_stream_stream(self): bidirectional_streaming_method(self._stub) spans = self.memory_exporter.get_finished_spans()