Merge branch 'srothh/worker-class-hierarchy' into srothh/async-task-worker

Merge changes of worker/transport ABC structure

Author: srothh

sentry_sdk/transport.py

@@ -107,6 +107,19 @@ def flush(
         """
         return None
 
+    async def flush_async(
+        self: Self,
+        timeout: float,
+        callback: Optional[Any] = None,
+    ) -> None:
+        """
+        Send out current events within `timeout` seconds. This method needs to be awaited for blocking behavior.
+
+        The default implementation is a no-op, since this method may only be relevant to some transports.
+        Subclasses should override this method if necessary.
+        """
+        return None
+
     def kill(self: Self) -> None:
         """
         Forcefully kills the transport.

sentry_sdk/worker.py

@@ -34,16 +34,29 @@ def is_alive(self) -> bool:
     def kill(self) -> None:
         pass
 
-    @abstractmethod
     def flush(
         self, timeout: float, callback: Optional[Callable[[int, float], None]] = None
     ) -> None:
         """
         Flush the worker.
 
         This method blocks until the worker has flushed all events or the specified timeout is reached.
+        Default implementation is a no-op, since this method may only be relevant to some workers.
+        Subclasses should override this method if necessary.
         """
-        pass
+        return None
+
+    async def flush_async(
+        self, timeout: float, callback: Optional[Callable[[int, float], None]] = None
+    ) -> None:
+        """
+        Flush the worker.
+
+        This method can be awaited until the worker has flushed all events or the specified timeout is reached.
+        Default implementation is a no-op, since this method may only be relevant to some workers.
+        Subclasses should override this method if necessary.
+        """
+        return None
 
     @abstractmethod
     def full(self) -> bool: