[skip ci]

Author: szokeasaurusrex

sentry_sdk/integrations/asgi.py

@@ -147,6 +147,7 @@ async def _run_asgi3(self, scope, receive, send):
 
     async def _run_app(self, scope, receive, send, asgi_version):
         # type: (Any, Any, Any, Any, int) -> Any
+        # breakpoint()
         is_recursive_asgi_middleware = _asgi_middleware_applied.get(False)
         is_lifespan = scope["type"] == "lifespan"
         if is_recursive_asgi_middleware or is_lifespan:

sentry_sdk/utils_py3.py

@@ -0,0 +1,31 @@
+from sentry_sdk.hub import Hub
+from functools import wraps
+
+from sentry_sdk._types import TYPE_CHECKING
+
+if TYPE_CHECKING:
+    from collections.abc import Awaitable, Callable
+    from typing import Optional
+    from sentry_sdk.integrations import Integration
+
+
+def integration_patched_async(original_function, integration=None):
+    # type: (Callable[..., Awaitable[object]], Optional[type[Integration]]) -> Callable[[Callable[..., Awaitable[object]]], object]
+    def patcher(sentry_patched_function):
+        # type: (Callable[..., Awaitable[object]]) -> Callable[..., object]
+        @wraps(original_function)
+        async def runner(*args, **kwargs):
+            # type: (*object, **object) -> object
+            breakpoint()
+            print("i am the runner")
+            if (
+                integration is not None
+                and Hub.current.get_integration(integration) is None
+            ):
+                return await original_function(*args, **kwargs)
+
+            return await sentry_patched_function(*args, **kwargs)
+
+        return runner
+
+    return patcher