fix(grpc): add isolation_scope to async server interceptor (#5940)

Create isolation scopes in the asynchronous gRPC interceptor to prevent scope bleed across concurrent requests.

Co-authored-by: Robin <robinvandijk@klippa.com>
Co-authored-by: Erica Pisani <hey@ericapisani.dev>

Author: 3 people

sentry_sdk/integrations/grpc/aio/server.py

@@ -43,31 +43,32 @@ async def intercept_service(
             handler_factory = grpc.unary_unary_rpc_method_handler
 
             async def wrapped(request: "Any", context: "ServicerContext") -> "Any":
-                name = self._find_method_name(context)
-                if not name:
-                    return await handler(request, context)
-
-                # What if the headers are empty?
-                transaction = sentry_sdk.continue_trace(
-                    dict(context.invocation_metadata()),
-                    op=OP.GRPC_SERVER,
-                    name=name,
-                    source=TransactionSource.CUSTOM,
-                    origin=SPAN_ORIGIN,
-                )
-
-                with sentry_sdk.start_transaction(transaction=transaction):
-                    try:
-                        return await handler.unary_unary(request, context)
-                    except AbortError:
-                        raise
-                    except Exception as exc:
-                        event, hint = event_from_exception(
-                            exc,
-                            mechanism={"type": "grpc", "handled": False},
-                        )
-                        sentry_sdk.capture_event(event, hint=hint)
-                        raise
+                with sentry_sdk.isolation_scope():
+                    name = self._find_method_name(context)
+                    if not name:
+                        return await handler(request, context)
+
+                    # What if the headers are empty?
+                    transaction = sentry_sdk.continue_trace(
+                        dict(context.invocation_metadata()),
+                        op=OP.GRPC_SERVER,
+                        name=name,
+                        source=TransactionSource.CUSTOM,
+                        origin=SPAN_ORIGIN,
+                    )
+
+                    with sentry_sdk.start_transaction(transaction=transaction):
+                        try:
+                            return await handler.unary_unary(request, context)
+                        except AbortError:
+                            raise
+                        except Exception as exc:
+                            event, hint = event_from_exception(
+                                exc,
+                                mechanism={"type": "grpc", "handled": False},
+                            )
+                            sentry_sdk.capture_event(event, hint=hint)
+                            raise
 
         elif not handler.request_streaming and handler.response_streaming:
             handler_factory = grpc.unary_stream_rpc_method_handler