Release v1.4.0 (#30)

austind · jscheffl · kaxil · web-flow · commit 5b0789f5c4be · 2025-10-23T15:30:13.000-05:00
* Add Python 3.13 support, drop 3.8 (#29) * Fix optional dependencies to avoid forcing installation of both httpx and requests (#26) - Move httpx and requests from core dependencies to optional extras - Add 'all' extra for users who want both libraries - Update README to reflect new installation instructions - Update noxfile to install both extras for testing Previously, both httpx and requests were always installed even when users only wanted one library. Now users can install only what they need: - retryhttp[all] for both libraries - retryhttp[httpx] for httpx only - retryhttp[requests] for requests only * Add support for aiohttp (#28) Co-authored-by: Austin de Coup-Crank <austindcc@gmail.com> * Release v1.4.0 --------- Co-authored-by: Jens Scheffler <95105677+jscheffl@users.noreply.github.com> Co-authored-by: Kaxil Naik <kaxilnaik@gmail.com>
diff --git a/.github/workflows/ci.yml b/.github/workflows/ci.yml
@@ -17,7 +17,7 @@ jobs:
       - name: Setup Nox
         uses: wntrblm/nox@2024.04.15
         with:
-          python-versions: "3.8, 3.9, 3.10, 3.11, 3.12"
+          python-versions: "3.9, 3.10, 3.11, 3.12, 3.13"
 
       - name: Run Nox
         run: nox -t test
diff --git a/README.md b/README.md
@@ -19,21 +19,22 @@ Several HTTP errors are often transient, and might succeed if retried:
 
 This project aims to simplify retrying these, by extending [`tenacity`](https://tenacity.readthedocs.io/) with custom retry and wait strategies, as well as a custom decorator. Defaults are sensible for most use cases, but are fully customizable.
 
-Supports both [`requests`](https://docs.python-requests.org/en/latest/index.html) and [`httpx`](https://python-httpx.org/) natively, but could be customized to use with any library that raises exceptions for the conditions listed above.
+Supports both [`requests`](https://docs.python-requests.org/en/latest/index.html), [`httpx`](https://python-httpx.org/) and [`aiohttp`](https://docs.aiohttp.org/) natively, but could be customized to use with any library that raises exceptions for the conditions listed above.
 
 ## Install
 
 Install from PyPI:
 
 ```sh
-pip install retryhttp  # Supports both HTTPX and requests
+pip install retryhttp  # Supports HTTPX, requests and aiohttp
 ```
 
 You can also install support for only HTTPX or requests, if you would rather not install unnecessary dependencies:
 
 ```sh
 pip install retryhttp[httpx]  # Supports only HTTPX
 pip install retryhttp[requests]  # Supports only requests
+pip install retryhttp[aiohttp]  # Supports only aiohttp
 ```
 
 Or, install the latest development snapshot from git:
diff --git a/docs/changelog.md b/docs/changelog.md
@@ -1,5 +1,11 @@
 # Changelog
 
+## v1.4.0
+
+* Added support for `aiohttp` ([#28])(https://github.com/austind/retryhttp/pull/28)
+* Dropped support for Python 3.8, added support for Python 3.13 ([#29](https://github.com/austind/retryhttp/pull/29))
+* Bugfix: Prevent installing both `requests` and `httpx` unless specified ([#26](https://github.com/austind/retryhttp/pull/26))
+
 ## v1.3.3
 
 * Bugfix: Pass error types to wait strategy in retry decorator ([#25](https://github.com/austind/retryhttp/pull/25))
diff --git a/docs/guide.md b/docs/guide.md
@@ -1,6 +1,6 @@
 ## Overview
 
-`retryhttp` makes it easy to retry potentially transient HTTP errors when using `httpx` or `requests`.
+`retryhttp` makes it easy to retry potentially transient HTTP errors when using `httpx`, `requests` or `aiohttp`.
 
 !!! note
     Errors that you can safely retry vary from service to service.
@@ -83,4 +83,4 @@ Under the hood, RetryHTTP is a convenience layer on top of the excellent retry l
 
 `tenacity` works by adding a decorator to functions that might fail. This decorator is configured with retry, wait, and stop strategies that configure what conditions to retry, how long to wait between retries, and when to stop retrying, respectively. Failures could be a raised exception, or a configurable return value. See [`tenacity` documentation](https://tenacity.readthedocs.io/en/latest/index.html) for details.
 
-`retryhttp` provides new retry and stop strategies for potentially transient error conditions raised by `httpx` and `requests`. To make things as convenient as possible, `retryhttp` also provides a [new decorator][retryhttp.retry] that wraps [`tenacity.retry`](https://tenacity.readthedocs.io/en/latest/api.html#tenacity.retry) with sensible defaults, which are all customizable.
+`retryhttp` provides new retry and stop strategies for potentially transient error conditions raised by `httpx`, `requests` and `aiohttp`. To make things as convenient as possible, `retryhttp` also provides a [new decorator][retryhttp.retry] that wraps [`tenacity.retry`](https://tenacity.readthedocs.io/en/latest/api.html#tenacity.retry) with sensible defaults, which are all customizable.
diff --git a/docs/index.md b/docs/index.md
@@ -17,14 +17,14 @@ Several HTTP errors are often transient, and might succeed if retried:
 
 This project aims to simplify retrying these, by extending [`tenacity`](https://tenacity.readthedocs.io/) with custom retry and wait strategies, as well as a custom decorator. Defaults are sensible for most use cases, but are fully customizable.
 
-Supports exceptions raised by both [`requests`](https://docs.python-requests.org/en/latest/index.html) and [`httpx`](https://python-httpx.org/).
+Supports exceptions raised by both [`requests`](https://docs.python-requests.org/en/latest/index.html), [`httpx`](https://python-httpx.org/) and [`aiohttp`](https://docs.aiohttp.org/).
 
 ## Install
 
 Install from PyPI:
 
 ```sh
-# Supports both HTTPX and requests
+# Supports HTTPX, requests and aiohttp
 pip install retryhttp
 ```
 
@@ -33,6 +33,7 @@ You can also install support for only HTTPX or requests:
 ```sh
 pip install retryhttp[httpx] # Supports only HTTPX
 pip install retryhttp[requests] # Supports only requests
+pip install retryhttp[aiohttp] # Supports only aiohttp
 ```
 
 Or, install the latest development snapshot from git:
diff --git a/noxfile.py b/noxfile.py
@@ -1,7 +1,7 @@
 import nox
 
 
-@nox.session(python=["3.8", "3.9", "3.10", "3.11", "3.12"], tags=["test"])
+@nox.session(python=["3.9", "3.10", "3.11", "3.12", "3.13"], tags=["test"])
 def test(session: nox.Session) -> None:
-    session.install(".", ".[dev]")
+    session.install(".[all,dev]")
     session.run("pytest", "-n", "4")
diff --git a/pyproject.toml b/pyproject.toml
@@ -1,11 +1,11 @@
 
 [project]
 name = "retryhttp"
-version = "1.3.3"
+version = "1.4.0"
 description = "Retry potentially transient HTTP errors in Python."
 license = {file = "LICENSE"}
 readme = "README.md"
-requires-python = ">=3.8"
+requires-python = ">=3.9"
 authors = [
   {name = "Austin de Coup-Crank", email = "austindcc@gmail.com"},
 ]
@@ -19,31 +19,35 @@ classifiers = [
     "Programming Language :: Python",
     "Programming Language :: Python :: 3",
     "Programming Language :: Python :: 3 :: Only",
-    "Programming Language :: Python :: 3.8",
     "Programming Language :: Python :: 3.9",
     "Programming Language :: Python :: 3.10",
     "Programming Language :: Python :: 3.11",
     "Programming Language :: Python :: 3.12",
+    "Programming Language :: Python :: 3.13",
     "Topic :: Internet :: WWW/HTTP",
     "Topic :: Utilities",
 ]
 dependencies = [
-    "httpx",
     "pydantic",
-    "requests",
-    "types-requests",
     "tenacity"
 ]
 
 
 [project.optional-dependencies]
 httpx = [
   "httpx",
-  "tenacity",
 ]
 requests = [
   "requests",
   "types-requests",
+]
+all = [
+  "httpx",
+  "requests",
+  "types-requests",
+]
+aiohttp = [
+  "aiohttp",
   "tenacity",
 ]
 dev = [
diff --git a/requirements.txt b/requirements.txt
@@ -1,3 +1,6 @@
 httpx
 tenacity
 pydantic
+aiohttp
+requests
+types-requests
diff --git a/retryhttp/_retry.py b/retryhttp/_retry.py
@@ -87,9 +87,11 @@ def retry(
         - `httpx.WriteError`
         - `requests.ConnectionError`
         - `requests.exceptions.ChunkedEncodingError`
+        - `aiohttp.ClientConnectionError`
     - Timeouts:
         - `httpx.TimeoutException`
         - `requests.Timeout`
+        - `aiohttp.ServerTimeoutError`
 
     Args:
         max_attempt_number: Total times to attempt a request. Includes the first attempt
@@ -112,11 +114,13 @@ def retry(
             - `httpx.WriteError`
             - `requests.ConnectError`
             - `requests.exceptions.ChunkedEncodingError`
+            - `aiohttp.ClientConnectionError`
         timeouts: One or more exceptions that will trigger `wait_timeouts` if
             `retry_timeouts` is `True`. Defaults to:
 
             - `httpx.TimeoutException`
             - `requests.Timeout`
+            - `aiohttp.ServerTimeoutError`
 
     Returns:
         Decorated function.
@@ -181,6 +185,7 @@ class retry_if_network_error(retry_if_exception_type):
             - `httpx.WriteError`
             - `requests.ConnectionError`
             - `requests.exceptions.ChunkedEncodingError`
+            - `aiohttp.ClientConnectionError`
 
     """
 
@@ -237,6 +242,8 @@ class retry_if_timeout(retry_if_exception_type):
             - `httpx.ReadTimeout`
             - `httpx.WriteTimeout`
             - `requests.Timeout`
+            - `aiohttp.ClientConnectionError`
+
     """
 
     def __init__(
diff --git a/retryhttp/_utils.py b/retryhttp/_utils.py
@@ -6,6 +6,7 @@
 
 _HTTPX_INSTALLED = False
 _REQUESTS_INSTALLED = False
+_AIOHTTP_INSTALLED = False
 
 try:
     import httpx
@@ -21,6 +22,13 @@
 except ImportError:
     pass
 
+try:
+    import aiohttp
+
+    _AIOHTTP_INSTALLED = True
+except ImportError:
+    pass
+
 
 def get_default_network_errors() -> Tuple[Type[BaseException], ...]:
     """Get all network errors to use by default.
@@ -51,6 +59,8 @@ def get_default_network_errors() -> Tuple[Type[BaseException], ...]:
                 requests.exceptions.ChunkedEncodingError,
             ]
         )
+    if _AIOHTTP_INSTALLED:
+        exceptions.append(aiohttp.ClientConnectionError)
     return tuple(exceptions)
 
 
@@ -66,6 +76,8 @@ def get_default_timeouts() -> Tuple[Type[BaseException], ...]:
         exceptions.append(httpx.TimeoutException)
     if _REQUESTS_INSTALLED:
         exceptions.append(requests.Timeout)
+    if _AIOHTTP_INSTALLED:
+        exceptions.append(aiohttp.ServerTimeoutError)
     return tuple(exceptions)
 
 
@@ -81,6 +93,8 @@ def get_default_http_status_exceptions() -> Tuple[Type[BaseException], ...]:
         exceptions.append(httpx.HTTPStatusError)
     if _REQUESTS_INSTALLED:
         exceptions.append(requests.HTTPError)
+    if _AIOHTTP_INSTALLED:
+        exceptions.append(aiohttp.ClientResponseError)
     return tuple(exceptions)
 
 
@@ -99,6 +113,8 @@ def is_rate_limited(exc: Optional[BaseException]) -> bool:
     exceptions = get_default_http_status_exceptions()
     if isinstance(exc, exceptions) and hasattr(exc, "response"):
         return exc.response.status_code == 429
+    if isinstance(exc, exceptions) and hasattr(exc, "status"):  # for aiohttp.ClientResponseError
+        return exc.status == 429
     return False
 
 
@@ -124,6 +140,8 @@ def is_server_error(
     exceptions = get_default_http_status_exceptions()
     if isinstance(exc, exceptions) and hasattr(exc, "response"):
         return exc.response.status_code in status_codes
+    if isinstance(exc, exceptions) and hasattr(exc, "status"):  # for aiohttp.ClientResponseError
+        return exc.status in status_codes
     return False
 
 
diff --git a/retryhttp/_wait.py b/retryhttp/_wait.py
@@ -70,24 +70,26 @@ def _get_wait_value(self, retry_state: RetryCallState) -> float:
             exc = retry_state.outcome.exception()
             if exc is None:
                 return 0
-            if isinstance(exc, get_default_http_status_exceptions()) and hasattr(
-                exc, "response"
-            ):
-                value = exc.response.headers.get(self.header)
-                if value is None:
-                    raise ValueError(f"Header not present: {self.header}")
-                if re.match(r"^\d+$", value):
-                    return float(value)
-                else:
-                    retry_after = datetime.strptime(value, HTTP_DATE_FORMAT)
-                    retry_after = retry_after.replace(tzinfo=timezone.utc)
-                    now = datetime.now(timezone.utc)
-                    if retry_after < now:
-                        raise ValueError(
-                            f'Date provided in header "{self.header}" '
-                            f"is in the past: {value}"
-                        )
-                    return float((retry_after - now).seconds)
+            value = None
+            if isinstance(exc, get_default_http_status_exceptions()):
+                if hasattr(exc, "response"):
+                    value = exc.response.headers.get(self.header)
+                elif hasattr(exc, "status"):  # for aiohttp.ClientResponseError
+                    value = exc.headers.get(self.header)
+            if value is None:
+                raise ValueError(f"Header not present: {self.header}")
+            if re.match(r"^\d+$", value):
+                return float(value)
+            else:
+                retry_after = datetime.strptime(value, HTTP_DATE_FORMAT)
+                retry_after = retry_after.replace(tzinfo=timezone.utc)
+                now = datetime.now(timezone.utc)
+                if retry_after < now:
+                    raise ValueError(
+                        f'Date provided in header "{self.header}" '
+                        f"is in the past: {value}"
+                    )
+                return float((retry_after - now).seconds)
         raise ValueError(f'Unable to parse wait time from header: "{self.header}"')
 
     def __call__(self, retry_state: RetryCallState) -> float:
@@ -162,13 +164,15 @@ class wait_context_aware(wait_base):
             - `httpx.WriteError`
             - `requests.ConnectionError`
             - `requests.exceptions.ChunkedEncodingError`
+            - `aiohttp.ClientConnectionError`
         timeouts: One or more exceptions that will trigger `wait_timeouts`. If omitted,
             defaults to:
 
             - `httpx.ConnectTimeout`
             - `httpx.ReadTimeout`
             - `httpx.WriteTimeout`
             - `requests.Timeout`
+            - `aiohttp.ServerTimeoutError`
 
     """
 
