resolve

Author: Mantisus

CHANGELOG.md

@@ -2,6 +2,22 @@
 
 All notable changes to this project will be documented in this file.
 
+<!-- git-cliff-unreleased-start -->
+## 1.12.3 - **not yet released**
+
+### 🚀 Features
+
+- 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)
+
+
+<!-- git-cliff-unreleased-end -->
+## [1.12.2](https://github.com/apify/apify-client-python/releases/tag/v1.12.2) (2025-08-08)
+
+### 🐛 Bug Fixes
+
+- Fix API error with stream ([#459](https://github.com/apify/apify-client-python/pull/459)) ([0c91ca5](https://github.com/apify/apify-client-python/commit/0c91ca516a01a6fca7bc8fa07f7bf9c15c75bf9d)) by [@Pijukatel](https://github.com/Pijukatel)
+
+
 ## [1.12.1](https://github.com/apify/apify-client-python/releases/tag/v1.12.1) (2025-07-30)
 
 ### 🐛 Bug Fixes
@@ -388,4 +404,4 @@ All notable changes to this project will be documented in this file.
 
 ## [0.0.1](https://github.com/apify/apify-client-python/releases/tag/v0.0.1) (2021-05-13)
 
-- Initial release of the package.
+- Initial release of the package.

pyproject.toml

@@ -4,7 +4,7 @@ build-backend = "hatchling.build"
 
 [project]
 name = "apify_client"
-version = "1.12.1"
+version = "1.12.3"
 description = "Apify API client for Python"
 authors = [{ name = "Apify Technologies s.r.o.", email = "support@apify.com" }]
 license = { file = "LICENSE" }

src/apify_client/clients/resource_clients/run_collection.py

@@ -26,7 +26,7 @@ def list(
         limit: int | None = None,
         offset: int | None = None,
         desc: bool | None = None,
-        status: ActorJobStatus | None = None,
+        status: ActorJobStatus | list[ActorJobStatus] | None = None,
     ) -> ListPage[dict]:
         """List all Actor runs.
 
@@ -40,16 +40,21 @@ def list(
             limit: How many runs to retrieve.
             offset: What run to include as first when retrieving the list.
             desc: Whether to sort the runs in descending order based on their start date.
-            status: Retrieve only runs with the provided status.
+            status: Retrieve only runs with the provided statuses.
 
         Returns:
             The retrieved Actor runs.
         """
+        if isinstance(status, list):
+            status_param = [maybe_extract_enum_member_value(s) for s in status]
+        else:
+            status_param = maybe_extract_enum_member_value(status)
+
         return self._list(
             limit=limit,
             offset=offset,
             desc=desc,
-            status=maybe_extract_enum_member_value(status),
+            status=status_param,
         )
 
 
@@ -67,7 +72,7 @@ async def list(
         limit: int | None = None,
         offset: int | None = None,
         desc: bool | None = None,
-        status: ActorJobStatus | None = None,
+        status: ActorJobStatus | list[ActorJobStatus] | None = None,
     ) -> ListPage[dict]:
         """List all Actor runs.
 
@@ -81,14 +86,19 @@ async def list(
             limit: How many runs to retrieve.
             offset: What run to include as first when retrieving the list.
             desc: Whether to sort the runs in descending order based on their start date.
-            status: Retrieve only runs with the provided status.
+            status: Retrieve only runs with the provided statuses.
 
         Returns:
             The retrieved Actor runs.
         """
+        if isinstance(status, list):
+            status_param = [maybe_extract_enum_member_value(s) for s in status]
+        else:
+            status_param = maybe_extract_enum_member_value(status)
+
         return await self._list(
             limit=limit,
             offset=offset,
             desc=desc,
-            status=maybe_extract_enum_member_value(status),
+            status=status_param,
         )

tests/integration/test_run_collection.py

@@ -0,0 +1,56 @@
+from __future__ import annotations
+
+from typing import TYPE_CHECKING
+
+import pytest
+
+if TYPE_CHECKING:
+    from apify_client import ApifyClient
+
+from apify_shared.consts import ActorJobStatus
+
+pytestmark = pytest.mark.integration
+
+
+class TestRunCollectionSync:
+    APIFY_HELLO_WORLD_ACTOR = 'apify/hello-world'
+    created_runs: list[dict]
+
+    def setup_runs(self, apify_client: ApifyClient) -> None:
+        self.created_runs = []
+
+        successfull_run = apify_client.actor(self.APIFY_HELLO_WORLD_ACTOR).call()
+        if successfull_run is not None:
+            self.created_runs.append(successfull_run)
+
+        timed_out_run = apify_client.actor(self.APIFY_HELLO_WORLD_ACTOR).call(timeout_secs=1)
+        if timed_out_run is not None:
+            self.created_runs.append(timed_out_run)
+
+    def teadown_runs(self, apify_client: ApifyClient) -> None:
+        for run in self.created_runs:
+            run_id = run.get('id')
+            if isinstance(run_id, str):
+                apify_client.run(run_id).delete()
+
+    async def test_run_collection_list_multiple_statuses(self, apify_client: ApifyClient) -> None:
+        self.setup_runs(apify_client)
+
+        run_collection = apify_client.actor(self.APIFY_HELLO_WORLD_ACTOR).runs()
+
+        multiple_status_runs = run_collection.list(status=[ActorJobStatus.SUCCEEDED, ActorJobStatus.TIMED_OUT])
+        single_status_runs = run_collection.list(status=ActorJobStatus.SUCCEEDED)
+
+        assert multiple_status_runs is not None
+        assert single_status_runs is not None
+
+        assert hasattr(multiple_status_runs, 'items')
+        assert hasattr(single_status_runs, 'items')
+
+        assert all(
+            run.get('status') in [ActorJobStatus.SUCCEEDED, ActorJobStatus.TIMED_OUT]
+            for run in multiple_status_runs.items
+        )
+        assert all(run.get('status') == ActorJobStatus.SUCCEEDED for run in single_status_runs.items)
+
+        self.teadown_runs(apify_client)

tests/unit/test_client_timeouts.py

@@ -150,6 +150,8 @@ def mock_request(*_args: Any, **kwargs: Any) -> Response:
 ]
 
 
+# This test will probably need to be reworked or skipped when switching to `impit`.
+# Without the mock library, it's difficult to reproduce, maybe with monkeypatch?
 @pytest.mark.parametrize(
     ('client_type', 'method', 'expected_timeout', 'kwargs'),
     _timeout_params,
@@ -171,6 +173,8 @@ def test_specific_timeouts_for_specific_endpoints_sync(
     assert patch_request[0] == expected_timeout
 
 
+# This test will probably need to be reworked or skipped when switching to `impit`.
+# Without the mock library, it's difficult to reproduce, maybe with monkeypatch?
 @pytest.mark.parametrize(
     ('client_type', 'method', 'expected_timeout', 'kwargs'),
     _timeout_params,

tests/unit/test_logging.py

@@ -242,9 +242,7 @@ def test_redirected_logs_sync(
 
     with caplog.at_level(logging.DEBUG, logger=logger_name), streamed_log:
         # Do stuff while the log from the other Actor is being redirected to the logs.
-        print(1)
         time.sleep(1)
-        print(2)
 
     # Ensure logs are propagated
     assert {(record.message, record.levelno) for record in caplog.records} == set(