Reformat

Author: zsol

sentry_sdk/integrations/arq.py

@@ -157,7 +157,9 @@ def event_processor(event: "Event", hint: "Hint") -> "Optional[Event]":
 
 
 def _wrap_coroutine(name: str, coroutine: "WorkerCoroutine") -> "WorkerCoroutine":
-    async def _sentry_coroutine(ctx: "Dict[Any, Any]", *args: "Any", **kwargs: "Any") -> "Any":
+    async def _sentry_coroutine(
+        ctx: "Dict[Any, Any]", *args: "Any", **kwargs: "Any"
+    ) -> "Any":
         integration = sentry_sdk.get_client().get_integration(ArqIntegration)
         if integration is None:
             return await coroutine(ctx, *args, **kwargs)

sentry_sdk/integrations/asyncpg.py

@@ -153,7 +153,9 @@ def _inner(*args: "Any", **kwargs: "Any") -> "T":  # noqa: N807
     return _inner
 
 
-def _wrap_connect_addr(f: "Callable[..., Awaitable[T]]") -> "Callable[..., Awaitable[T]]":
+def _wrap_connect_addr(
+    f: "Callable[..., Awaitable[T]]",
+) -> "Callable[..., Awaitable[T]]":
     async def _inner(*args: "Any", **kwargs: "Any") -> "T":
         if sentry_sdk.get_client().get_integration(AsyncPGIntegration) is None:
             return await f(*args, **kwargs)

sentry_sdk/integrations/executing.py

@@ -22,7 +22,9 @@ class ExecutingIntegration(Integration):
     @staticmethod
     def setup_once() -> None:
         @add_global_event_processor
-        def add_executing_info(event: "Event", hint: "Optional[Hint]") -> "Optional[Event]":
+        def add_executing_info(
+            event: "Event", hint: "Optional[Hint]"
+        ) -> "Optional[Event]":
             if sentry_sdk.get_client().get_integration(ExecutingIntegration) is None:
                 return event
 

sentry_sdk/integrations/google_genai/__init__.py

@@ -64,7 +64,9 @@ def setup_once() -> None:
 
 def _wrap_generate_content_stream(f: "Callable[..., Any]") -> "Callable[..., Any]":
     @wraps(f)
-    def new_generate_content_stream(self: "Any", *args: "Any", **kwargs: "Any") -> "Any":
+    def new_generate_content_stream(
+        self: "Any", *args: "Any", **kwargs: "Any"
+    ) -> "Any":
         integration = sentry_sdk.get_client().get_integration(GoogleGenAIIntegration)
         if integration is None:
             return f(self, *args, **kwargs)
@@ -256,7 +258,9 @@ def new_generate_content(self: "Any", *args: "Any", **kwargs: "Any") -> "Any":
 
 def _wrap_async_generate_content(f: "Callable[..., Any]") -> "Callable[..., Any]":
     @wraps(f)
-    async def new_async_generate_content(self: "Any", *args: "Any", **kwargs: "Any") -> "Any":
+    async def new_async_generate_content(
+        self: "Any", *args: "Any", **kwargs: "Any"
+    ) -> "Any":
         integration = sentry_sdk.get_client().get_integration(GoogleGenAIIntegration)
         if integration is None:
             return await f(self, *args, **kwargs)
@@ -333,7 +337,9 @@ def new_embed_content(self: "Any", *args: "Any", **kwargs: "Any") -> "Any":
 
 def _wrap_async_embed_content(f: "Callable[..., Any]") -> "Callable[..., Any]":
     @wraps(f)
-    async def new_async_embed_content(self: "Any", *args: "Any", **kwargs: "Any") -> "Any":
+    async def new_async_embed_content(
+        self: "Any", *args: "Any", **kwargs: "Any"
+    ) -> "Any":
         integration = sentry_sdk.get_client().get_integration(GoogleGenAIIntegration)
         if integration is None:
             return await f(self, *args, **kwargs)

sentry_sdk/integrations/grpc/__init__.py

@@ -80,7 +80,9 @@ def patched_intercept_channel(
     return patched_intercept_channel  # type: ignore
 
 
-def _wrap_channel_async(func: "Callable[P, AsyncChannel]") -> "Callable[P, AsyncChannel]":
+def _wrap_channel_async(
+    func: "Callable[P, AsyncChannel]",
+) -> "Callable[P, AsyncChannel]":
     "Wrapper for asynchronous secure and insecure channel."
 
     @wraps(func)

sentry_sdk/integrations/pure_eval.py

@@ -37,7 +37,9 @@ class PureEvalIntegration(Integration):
     @staticmethod
     def setup_once() -> None:
         @add_global_event_processor
-        def add_executing_info(event: "Event", hint: "Optional[Hint]") -> "Optional[Event]":
+        def add_executing_info(
+            event: "Event", hint: "Optional[Hint]"
+        ) -> "Optional[Event]":
             if sentry_sdk.get_client().get_integration(PureEvalIntegration) is None:
                 return event
 

sentry_sdk/integrations/starlette.py

@@ -456,7 +456,9 @@ async def _sentry_async_func(*args: "Any", **kwargs: "Any") -> "Any":
                 def _make_request_event_processor(
                     req: "Any", integration: "Any"
                 ) -> "Callable[[Event, dict[str, Any]], Event]":
-                    def event_processor(event: "Event", hint: "Dict[str, Any]") -> "Event":
+                    def event_processor(
+                        event: "Event", hint: "Dict[str, Any]"
+                    ) -> "Event":
                         # Add info from request to event
                         request_info = event.get("request", {})
                         if info:
@@ -509,7 +511,9 @@ def _sentry_sync_func(*args: "Any", **kwargs: "Any") -> "Any":
                 def _make_request_event_processor(
                     req: "Any", integration: "Any"
                 ) -> "Callable[[Event, dict[str, Any]], Event]":
-                    def event_processor(event: "Event", hint: "dict[str, Any]") -> "Event":
+                    def event_processor(
+                        event: "Event", hint: "dict[str, Any]"
+                    ) -> "Event":
                         # Extract information from request
                         request_info = event.get("request", {})
                         if cookies: