move is_retryable_error in utils

Author: Mantisus

src/apify_client/_http_client.py

@@ -14,8 +14,8 @@
 
 from apify_client._logging import log_context, logger_name
 from apify_client._statistics import Statistics
-from apify_client._utils import retry_with_exp_backoff, retry_with_exp_backoff_async
-from apify_client.errors import ApifyApiError, InvalidResponseBodyError, is_retryable_error
+from apify_client._utils import is_retryable_error, retry_with_exp_backoff, retry_with_exp_backoff_async
+from apify_client.errors import ApifyApiError, InvalidResponseBodyError
 
 if TYPE_CHECKING:
     from collections.abc import Callable

src/apify_client/_utils.py

@@ -9,8 +9,11 @@
 from http import HTTPStatus
 from typing import TYPE_CHECKING, Any, TypeVar, cast
 
+import httpx
 from apify_shared.utils import is_file_or_bytes, maybe_extract_enum_member_value
 
+from apify_client.errors import InvalidResponseBodyError
+
 if TYPE_CHECKING:
     from collections.abc import Awaitable
 
@@ -149,3 +152,16 @@ def encode_key_value_store_record_value(value: Any, content_type: str | None = N
         value = json.dumps(value, ensure_ascii=False, indent=2, allow_nan=False, default=str).encode('utf-8')
 
     return (value, content_type)
+
+
+def is_retryable_error(exc: Exception) -> bool:
+    """Check if the given error is retryable."""
+    return isinstance(
+        exc,
+        (
+            InvalidResponseBodyError,
+            httpx.NetworkError,
+            httpx.TimeoutException,
+            httpx.RemoteProtocolError,
+        ),
+    )

src/apify_client/errors.py

@@ -1,8 +1,12 @@
 from __future__ import annotations
 
-import httpx
+from typing import TYPE_CHECKING
+
 from apify_shared.utils import ignore_docs
 
+if TYPE_CHECKING:
+    import httpx
+
 
 class ApifyClientError(Exception):
     """Base class for errors specific to the Apify API Client."""
@@ -72,16 +76,3 @@ def __init__(self, response: httpx.Response) -> None:
         self.name = 'InvalidResponseBodyError'
         self.code = 'invalid-response-body'
         self.response = response
-
-
-def is_retryable_error(exc: Exception) -> bool:
-    """Check if the given error is retryable."""
-    return isinstance(
-        exc,
-        (
-            InvalidResponseBodyError,
-            httpx.NetworkError,
-            httpx.TimeoutException,
-            httpx.RemoteProtocolError,
-        ),
-    )