inline get_client()

Author: alexander-alderman-webb

sentry_sdk/integrations/grpc/aio/client.py

@@ -50,9 +50,7 @@ async def intercept_unary_unary(
     ) -> "Union[UnaryUnaryCall, Message]":
         method = client_call_details.method
 
-        client = sentry_sdk.get_client()
-        span_streaming = has_span_streaming_enabled(client.options)
-
+        span_streaming = has_span_streaming_enabled(sentry_sdk.get_client().options)
         if span_streaming:
             with sentry_sdk.traces.start_span(
                 name="unary unary call to %s" % method.decode(),
@@ -107,9 +105,7 @@ async def intercept_unary_stream(
     ) -> "Union[AsyncIterable[Any], UnaryStreamCall]":
         method = client_call_details.method
 
-        client = sentry_sdk.get_client()
-        span_streaming = has_span_streaming_enabled(client.options)
-
+        span_streaming = has_span_streaming_enabled(sentry_sdk.get_client().options)
         if span_streaming:
             with sentry_sdk.traces.start_span(
                 name="unary stream call to %s" % method.decode(),

sentry_sdk/integrations/grpc/aio/server.py

@@ -53,8 +53,9 @@ async def wrapped(request: "Any", context: "ServicerContext") -> "Any":
                     if not name:
                         return await handler(request, context)
 
-                    client = sentry_sdk.get_client()
-                    span_streaming = has_span_streaming_enabled(client.options)
+                    span_streaming = has_span_streaming_enabled(
+                        sentry_sdk.get_client().options
+                    )
                     if span_streaming:
                         # What if the headers are empty?
                         sentry_sdk.traces.continue_trace(

sentry_sdk/integrations/grpc/client.py

@@ -31,8 +31,7 @@ def intercept_unary_unary(
     ) -> "_UnaryOutcome":
         method = client_call_details.method
 
-        client = sentry_sdk.get_client()
-        span_streaming = has_span_streaming_enabled(client.options)
+        span_streaming = has_span_streaming_enabled(sentry_sdk.get_client().options)
         if span_streaming:
             with sentry_sdk.traces.start_span(
                 name="unary unary call to %s" % method,
@@ -82,8 +81,7 @@ def intercept_unary_stream(
     ) -> "Union[Iterator[Message], Call]":
         method = client_call_details.method
 
-        client = sentry_sdk.get_client()
-        span_streaming = has_span_streaming_enabled(client.options)
+        span_streaming = has_span_streaming_enabled(sentry_sdk.get_client().options)
         response: "UnaryStreamCall"
         if span_streaming:
             with sentry_sdk.traces.start_span(

sentry_sdk/integrations/grpc/server.py

@@ -46,8 +46,9 @@ def behavior(request: "Message", context: "ServicerContext") -> "Message":
                 if name:
                     metadata = dict(context.invocation_metadata())
 
-                    client = sentry_sdk.get_client()
-                    span_streaming = has_span_streaming_enabled(client.options)
+                    span_streaming = has_span_streaming_enabled(
+                        sentry_sdk.get_client().options
+                    )
                     if span_streaming:
                         sentry_sdk.traces.continue_trace(metadata)