resolve

Author: Mantisus

.github/workflows/_async_docstrings_check.yaml

@@ -13,7 +13,7 @@ jobs:
 
     steps:
       - name: Checkout repository
-        uses: actions/checkout@v4
+        uses: actions/checkout@v5
 
       - name: Set up Python
         uses: actions/setup-python@v5

.github/workflows/build_and_deploy_docs.yaml

@@ -22,7 +22,7 @@ jobs:
 
     steps:
       - name: Checkout repository
-        uses: actions/checkout@v4
+        uses: actions/checkout@v5
         with:
           token: ${{ secrets.APIFY_SERVICE_ACCOUNT_GITHUB_TOKEN }}
 

CHANGELOG.md

@@ -9,6 +9,10 @@ All notable changes to this project will be documented in this file.
 
 - Extend status parameter to an array of possible statuses  ([#455](https://github.com/apify/apify-client-python/pull/455)) ([76f6769](https://github.com/apify/apify-client-python/commit/76f676973d067ce8af398d8e6ceea55595da5ecf)) by [@JanHranicky](https://github.com/JanHranicky)
 
+### Refactor
+
+- [**breaking**] Remove support for passing a single string to the `unwind` parameter in `DatasetClient` ([#467](https://github.com/apify/apify-client-python/pull/467)) ([e8aea2c](https://github.com/apify/apify-client-python/commit/e8aea2c8f3833082bf78562f3fa981a1f8e88b26)) by [@Mantisus](https://github.com/Mantisus), closes [#255](https://github.com/apify/apify-client-python/issues/255)
+
 
 <!-- git-cliff-unreleased-end -->
 ## [1.12.2](https://github.com/apify/apify-client-python/releases/tag/v1.12.2) (2025-08-08)

docs/02_concepts/09_streaming.mdx

@@ -18,7 +18,7 @@ Supported streaming methods:
 - [`KeyValueStoreClient.stream_record`](/reference/class/KeyValueStoreClient#stream_record) - Stream key-value store records as raw data.
 - [`LogClient.stream`](/reference/class/LogClient#stream) - Stream logs in real time.
 
-These methods return a raw, context-managed `httpx.Response` object. The response must be consumed within a with block to ensure that the connection is closed automatically, preventing memory leaks or unclosed connections.
+These methods return a raw, context-managed `impit.Response` object. The response must be consumed within a with block to ensure that the connection is closed automatically, preventing memory leaks or unclosed connections.
 
 The following example demonstrates how to stream the logs of an Actor run incrementally:
 

docs/02_concepts/code/01_async_support.py

@@ -17,8 +17,8 @@ async def main() -> None:
     # Stream the logs
     async with log_client.stream() as async_log_stream:
         if async_log_stream:
-            async for line in async_log_stream.aiter_lines():
-                print(line)
+            async for bytes_chunk in async_log_stream.aiter_bytes():
+                print(bytes_chunk)
 
 
 if __name__ == '__main__':

docs/02_concepts/code/09_streaming_async.py

@@ -10,5 +10,5 @@ async def main() -> None:
 
     async with log_client.stream() as log_stream:
         if log_stream:
-            for line in log_stream.iter_lines():
-                print(line)
+            async for bytes_chunk in log_stream.aiter_bytes():
+                print(bytes_chunk)

docs/02_concepts/code/09_streaming_sync.py

@@ -10,5 +10,5 @@ def main() -> None:
 
     with log_client.stream() as log_stream:
         if log_stream:
-            for line in log_stream.iter_lines():
-                print(line)
+            for bytes_chunk in log_stream.iter_bytes():
+                print(bytes_chunk)

docs/04_upgrading/upgrading_to_v2.md

@@ -0,0 +1,18 @@
+---
+id: upgrading-to-v2
+title: Upgrading to v2
+---
+
+This page summarizes the breaking changes between Apify Python API client v1.x and v2.0.
+
+## Python version support
+
+<!-- TODO -->
+
+## Change underlying HTTP library
+
+In v2.0, the Apify Python API client switched from using `httpx` to [`impit`](https://github.com/apify/impit) as the underlying HTTP library.
+
+## Update signature of methods
+
+<!-- TODO -->

pyproject.toml

@@ -27,7 +27,7 @@ keywords = ["apify", "api", "client", "automation", "crawling", "scraping"]
 dependencies = [
     "apify-shared<2.0.0",
     "colorama>=0.4.0",
-    "httpx>=0.25",
+    "impit>=0.5.2",
     "more_itertools>=10.0.0",
 ]
 
@@ -42,23 +42,22 @@ dependencies = [
 
 [dependency-groups]
 dev = [
-    "dycw-pytest-only>=2.1.1",
+    "dycw-pytest-only~=2.1.0",
     "griffe~=1.11.0",
     "mypy~=1.17.0",
     "pre-commit~=4.3.0",
     "pydoc-markdown~=4.8.0",
     "pytest-asyncio~=1.1.0",
     "pytest-cov~=6.2.0",
-    "pytest-timeout>=2.4.0",
+    "pytest-timeout~=2.4.0",
     "pytest-xdist~=3.8.0",
     "pytest~=8.4.0",
-    "pytest-httpserver>=1.1.3",
+    "pytest-httpserver~=1.1.0",
     "redbaron~=0.9.0",
-    "respx~=0.22.0",
     "ruff~=0.12.0",
     "setuptools", # setuptools are used by pytest but not explicitly required
     "types-colorama~=0.4.15.20240106",
-    "werkzeug~=3.0.0", # Werkzeug is used by pytest-httpserver
+    "werkzeug~=3.1.0", # Werkzeug is used by pytest-httpserver
 ]
 
 [tool.hatch.build.targets.wheel]
@@ -175,7 +174,7 @@ warn_unused_ignores = true
 exclude = []
 
 [[tool.mypy.overrides]]
-module = ["pandas", "respx"]
+module = ["pandas"]
 ignore_missing_imports = true
 
 [tool.basedpyright]

src/apify_client/_errors.py

@@ -1,6 +1,8 @@
 from __future__ import annotations
 
-import httpx
+import json as jsonlib
+
+import impit
 from apify_shared.utils import ignore_docs
 
 
@@ -17,20 +19,21 @@ class ApifyApiError(ApifyClientError):
     """
 
     @ignore_docs
-    def __init__(self, response: httpx.Response, attempt: int) -> None:
+    def __init__(self, response: impit.Response, attempt: int, method: str = 'GET') -> None:
         """Initialize a new instance.
 
         Args:
             response: The response to the failed API call.
             attempt: Which attempt was the request that failed.
+            method: The HTTP method used for the request.
         """
         self.message: str | None = None
         self.type: str | None = None
         self.data = dict[str, str]()
 
         self.message = f'Unexpected error: {response.text}'
         try:
-            response_data = response.json()
+            response_data = jsonlib.loads(response.text)
             if 'error' in response_data:
                 self.message = response_data['error']['message']
                 self.type = response_data['error']['type']
@@ -44,7 +47,7 @@ def __init__(self, response: httpx.Response, attempt: int) -> None:
         self.name = 'ApifyApiError'
         self.status_code = response.status_code
         self.attempt = attempt
-        self.http_method = response.request.method
+        self.http_method = method
 
         # TODO: self.client_method   # noqa: TD003
         # TODO: self.original_stack  # noqa: TD003
@@ -61,7 +64,7 @@ class InvalidResponseBodyError(ApifyClientError):
     """
 
     @ignore_docs
-    def __init__(self, response: httpx.Response) -> None:
+    def __init__(self, response: impit.Response) -> None:
         """Initialize a new instance.
 
         Args:
@@ -80,8 +83,8 @@ def is_retryable_error(exc: Exception) -> bool:
         exc,
         (
             InvalidResponseBodyError,
-            httpx.NetworkError,
-            httpx.TimeoutException,
-            httpx.RemoteProtocolError,
+            impit.NetworkError,
+            impit.TimeoutException,
+            impit.RemoteProtocolError,
         ),
     )