Testing

Author: mephenor

src/ghga_service_commons/transports/retry.py

@@ -21,9 +21,11 @@
 from typing import Any, Self
 
 import httpx
+import tenacity
 from tenacity import (
     AsyncRetrying,
     RetryCallState,
+    RetryError,
     retry_if_exception_type,
     retry_if_result,
     stop_after_attempt,
@@ -98,9 +100,13 @@ async def handle_async_request(self, request: httpx.Request) -> httpx.Response:
         :return: An HTTP response
         :rtype: httpx.Response
         """
-        response = await self._retry_handler(
-            fn=self._transport.handle_async_request, request=request
-        )
+        try:
+            response = await self._retry_handler(
+                fn=self._transport.handle_async_request, request=request
+            )
+        except RetryError as exc:
+            if isinstance(exc.last_attempt, tenacity.Future):
+                raise ValueError(exc.last_attempt.result()) from exc
         return response
 
     async def aclose(self) -> None:  # noqa: D102