Update

Author: vdusek

src/apify_client/_models.py

@@ -1,6 +1,6 @@
 # generated by datamodel-codegen:
 #   filename:  openapi.json
-#   timestamp: 2026-01-21T16:38:20+00:00
+#   timestamp: 2026-01-21T21:58:10+00:00
 
 from __future__ import annotations
 
@@ -470,7 +470,7 @@ class ActorJobStatus(Enum):
 class BuildsMeta(BaseModel):
     origin: Annotated[str, Field(examples=['WEB'])]
     client_ip: Annotated[IPv4Address | None, Field(alias='clientIp', examples=['172.234.12.34'])] = None
-    user_agent: Annotated[str, Field(alias='userAgent', examples=['Mozilla/5.0 (iPad)'])]
+    user_agent: Annotated[str | None, Field(alias='userAgent', examples=['Mozilla/5.0 (iPad)'])] = None
 
 
 class BuildShort(BaseModel):
@@ -1290,16 +1290,16 @@ class KeyValueStore(BaseModel):
     act_id: Annotated[str | None, Field(alias='actId', examples=[None])] = None
     act_run_id: Annotated[str | None, Field(alias='actRunId', examples=[None])] = None
     console_url: Annotated[
-        AnyUrl,
+        AnyUrl | None,
         Field(alias='consoleUrl', examples=['https://console.apify.com/storage/key-value-stores/27TmTznX9YPeAYhkC']),
-    ]
+    ] = None
     keys_public_url: Annotated[
-        AnyUrl,
+        AnyUrl | None,
         Field(
             alias='keysPublicUrl',
             examples=['https://api.apify.com/v2/key-value-stores/WkzbQMuFYuamGv3YF/keys?signature=abc123'],
         ),
-    ]
+    ] = None
     """
     A public link to access keys of the key-value store directly.
     """
@@ -1592,7 +1592,7 @@ class RequestQueueShort(BaseModel):
     """
     The timestamp when the request queue was last accessed.
     """
-    expire_at: Annotated[AwareDatetime, Field(alias='expireAt', examples=['2019-06-02T17:15:06.751Z'])]
+    expire_at: Annotated[AwareDatetime | None, Field(alias='expireAt', examples=['2019-06-02T17:15:06.751Z'])] = None
     """
     The timestamp when the request queue will expire and be deleted.
     """
@@ -2164,7 +2164,7 @@ class EventData(BaseModel):
     actor_run_id: Annotated[str, Field(alias='actorRunId', examples=['JgwXN9BdwxGcu9MMF'])]
 
 
-class Calls(BaseModel):
+class Call(BaseModel):
     started_at: Annotated[AwareDatetime | None, Field(alias='startedAt', examples=['2019-12-12T07:34:14.202Z'])] = None
     finished_at: Annotated[AwareDatetime | None, Field(alias='finishedAt', examples=['2019-12-12T07:34:14.202Z'])] = (
         None
@@ -2181,8 +2181,8 @@ class WebhookDispatch(BaseModel):
     created_at: Annotated[AwareDatetime, Field(alias='createdAt', examples=['2019-12-12T07:34:14.202Z'])]
     status: Annotated[str, Field(examples=['SUCCEEDED'])]
     event_type: Annotated[str, Field(alias='eventType', examples=['ACTOR.RUN.SUCCEEDED'])]
-    event_data: Annotated[EventData, Field(alias='eventData', title='eventData')]
-    calls: Annotated[Calls | None, Field(title='calls')] = None
+    event_data: Annotated[EventData | None, Field(alias='eventData', title='eventData')] = None
+    calls: Annotated[list[Call] | None, Field(title='calls')] = None
 
 
 class TestWebhookResponse(BaseModel):
@@ -2467,30 +2467,22 @@ class PriceTiers(BaseModel):
 class UsageItem(BaseModel):
     quantity: Annotated[float, Field(examples=[2.784475])]
     base_amount_usd: Annotated[float, Field(alias='baseAmountUsd', examples=[0.69611875])]
-    base_unit_price_usd: Annotated[float, Field(alias='baseUnitPriceUsd', examples=[0.25])]
+    base_unit_price_usd: Annotated[float | None, Field(alias='baseUnitPriceUsd', examples=[0.25])] = None
     amount_after_volume_discount_usd: Annotated[
-        float, Field(alias='amountAfterVolumeDiscountUsd', examples=[0.69611875])
-    ]
-    price_tiers: Annotated[list[PriceTiers], Field(alias='priceTiers')]
-
-
-class MonthlyServiceUsage(BaseModel):
-    usage_item: Annotated[UsageItem, Field(alias='USAGE_ITEM')]
-
-
-class ServiceUsage(BaseModel):
-    service_usage_item: Annotated[UsageItem, Field(alias='SERVICE_USAGE_ITEM')]
+        float | None, Field(alias='amountAfterVolumeDiscountUsd', examples=[0.69611875])
+    ] = None
+    price_tiers: Annotated[list[PriceTiers] | None, Field(alias='priceTiers')] = None
 
 
 class DailyServiceUsages(BaseModel):
     date: Annotated[str, Field(examples=['2022-10-02T00:00:00.000Z'])]
-    service_usage: Annotated[ServiceUsage, Field(alias='serviceUsage')]
+    service_usage: Annotated[dict[str, UsageItem], Field(alias='serviceUsage')]
     total_usage_credits_usd: Annotated[float, Field(alias='totalUsageCreditsUsd', examples=[0.0474385791970591])]
 
 
 class MonthlyUsage(BaseModel):
     usage_cycle: Annotated[UsageCycle, Field(alias='usageCycle')]
-    monthly_service_usage: Annotated[MonthlyServiceUsage, Field(alias='monthlyServiceUsage')]
+    monthly_service_usage: Annotated[dict[str, UsageItem], Field(alias='monthlyServiceUsage')]
     daily_service_usages: Annotated[list[DailyServiceUsages], Field(alias='dailyServiceUsages')]
     total_usage_credits_usd_before_volume_discount: Annotated[
         float, Field(alias='totalUsageCreditsUsdBeforeVolumeDiscount', examples=[0.786143673840067])

src/apify_client/_resource_clients/base/resource_collection_client.py

@@ -18,7 +18,7 @@ def _list(self, **kwargs: Any) -> ListPage:
         )
 
         data = response_to_dict(response)
-        return ListPage(data)
+        return ListPage(data.get('data', data))
 
     def _create(self, resource: dict) -> dict:
         response = self.http_client.call(
@@ -52,7 +52,7 @@ async def _list(self, **kwargs: Any) -> ListPage:
         )
 
         data = response_to_dict(response)
-        return ListPage(data)
+        return ListPage(data.get('data', data))
 
     async def _create(self, resource: dict) -> dict:
         response = await self.http_client.call(

src/apify_client/_resource_clients/build.py

@@ -2,7 +2,7 @@
 
 from typing import Any
 
-from apify_client._models import Build
+from apify_client._models import Build, GetBuildResponse, PostAbortBuildResponse
 from apify_client._resource_clients.base import ActorJobBaseClient, ActorJobBaseClientAsync
 from apify_client._resource_clients.log import LogClient, LogClientAsync
 
@@ -23,7 +23,7 @@ def get(self) -> Build | None:
             The retrieved Actor build data.
         """
         result = self._get()
-        return Build.model_validate(result) if result is not None else None
+        return GetBuildResponse.model_validate(result).data if result is not None else None
 
     def delete(self) -> None:
         """Delete the build.
@@ -41,7 +41,7 @@ def abort(self) -> Build:
             The data of the aborted Actor build.
         """
         result = self._abort()
-        return Build.model_validate(result)
+        return PostAbortBuildResponse.model_validate(result).data
 
     def get_open_api_definition(self) -> dict | None:
         """Return OpenAPI definition of the Actor's build.
@@ -102,7 +102,7 @@ async def get(self) -> Build | None:
             The retrieved Actor build data.
         """
         result = await self._get()
-        return Build.model_validate(result) if result is not None else None
+        return GetBuildResponse.model_validate(result).data if result is not None else None
 
     async def abort(self) -> Build:
         """Abort the Actor build which is starting or currently running and return its details.
@@ -113,7 +113,7 @@ async def abort(self) -> Build:
             The data of the aborted Actor build.
         """
         result = await self._abort()
-        return Build.model_validate(result)
+        return PostAbortBuildResponse.model_validate(result).data
 
     async def delete(self) -> None:
         """Delete the build.

src/apify_client/_resource_clients/dataset_collection.py

@@ -1,13 +1,10 @@
 from __future__ import annotations
 
-from typing import TYPE_CHECKING, Any
+from typing import Any
 
-from apify_client._models import Dataset, DatasetListItem, DatasetResponse
+from apify_client._models import Dataset, DatasetResponse, GetListOfDatasetsResponse, ListOfDatasets
 from apify_client._resource_clients.base import ResourceCollectionClient, ResourceCollectionClientAsync
-from apify_client._utils import filter_out_none_values_recursively
-
-if TYPE_CHECKING:
-    from apify_client._types import ListPage
+from apify_client._utils import filter_out_none_values_recursively, response_to_dict
 
 
 class DatasetCollectionClient(ResourceCollectionClient):
@@ -24,7 +21,7 @@ def list(
         limit: int | None = None,
         offset: int | None = None,
         desc: bool | None = None,
-    ) -> ListPage[DatasetListItem]:
+    ) -> ListOfDatasets:
         """List the available datasets.
 
         https://docs.apify.com/api/v2#/reference/datasets/dataset-collection/get-list-of-datasets
@@ -38,7 +35,13 @@ def list(
         Returns:
             The list of available datasets matching the specified filters.
         """
-        return self._list(unnamed=unnamed, limit=limit, offset=offset, desc=desc)
+        response = self.http_client.call(
+            url=self._url(),
+            method='GET',
+            params=self._params(unnamed=unnamed, limit=limit, offset=offset, desc=desc),
+        )
+        data = response_to_dict(response)
+        return GetListOfDatasetsResponse.model_validate(data).data
 
     def get_or_create(self, *, name: str | None = None, schema: dict | None = None) -> Dataset:
         """Retrieve a named dataset, or create a new one when it doesn't exist.
@@ -70,7 +73,7 @@ async def list(
         limit: int | None = None,
         offset: int | None = None,
         desc: bool | None = None,
-    ) -> ListPage[DatasetListItem]:
+    ) -> ListOfDatasets:
         """List the available datasets.
 
         https://docs.apify.com/api/v2#/reference/datasets/dataset-collection/get-list-of-datasets
@@ -84,7 +87,13 @@ async def list(
         Returns:
             The list of available datasets matching the specified filters.
         """
-        return await self._list(unnamed=unnamed, limit=limit, offset=offset, desc=desc)
+        response = await self.http_client.call(
+            url=self._url(),
+            method='GET',
+            params=self._params(unnamed=unnamed, limit=limit, offset=offset, desc=desc),
+        )
+        data = response_to_dict(response)
+        return GetListOfDatasetsResponse.model_validate(data).data
 
     async def get_or_create(
         self,

src/apify_client/_resource_clients/key_value_store_collection.py

@@ -1,13 +1,15 @@
 from __future__ import annotations
 
-from typing import TYPE_CHECKING, Any
-
-from apify_client._models import CreateKeyValueStoreResponse, KeyValueStore
+from typing import Any
+
+from apify_client._models import (
+    CreateKeyValueStoreResponse,
+    GetListOfKeyValueStoresResponse,
+    KeyValueStore,
+    ListOfKeyValueStores,
+)
 from apify_client._resource_clients.base import ResourceCollectionClient, ResourceCollectionClientAsync
-from apify_client._utils import filter_out_none_values_recursively
-
-if TYPE_CHECKING:
-    from apify_client._types import ListPage
+from apify_client._utils import filter_out_none_values_recursively, response_to_dict
 
 
 class KeyValueStoreCollectionClient(ResourceCollectionClient):
@@ -24,7 +26,7 @@ def list(
         limit: int | None = None,
         offset: int | None = None,
         desc: bool | None = None,
-    ) -> ListPage[KeyValueStore]:
+    ) -> ListOfKeyValueStores:
         """List the available key-value stores.
 
         https://docs.apify.com/api/v2#/reference/key-value-stores/store-collection/get-list-of-key-value-stores
@@ -38,7 +40,13 @@ def list(
         Returns:
             The list of available key-value stores matching the specified filters.
         """
-        return self._list(unnamed=unnamed, limit=limit, offset=offset, desc=desc)
+        response = self.http_client.call(
+            url=self._url(),
+            method='GET',
+            params=self._params(unnamed=unnamed, limit=limit, offset=offset, desc=desc),
+        )
+        data = response_to_dict(response)
+        return GetListOfKeyValueStoresResponse.model_validate(data).data
 
     def get_or_create(
         self,
@@ -75,7 +83,7 @@ async def list(
         limit: int | None = None,
         offset: int | None = None,
         desc: bool | None = None,
-    ) -> ListPage[KeyValueStore]:
+    ) -> ListOfKeyValueStores:
         """List the available key-value stores.
 
         https://docs.apify.com/api/v2#/reference/key-value-stores/store-collection/get-list-of-key-value-stores
@@ -89,7 +97,13 @@ async def list(
         Returns:
             The list of available key-value stores matching the specified filters.
         """
-        return await self._list(unnamed=unnamed, limit=limit, offset=offset, desc=desc)
+        response = await self.http_client.call(
+            url=self._url(),
+            method='GET',
+            params=self._params(unnamed=unnamed, limit=limit, offset=offset, desc=desc),
+        )
+        data = response_to_dict(response)
+        return GetListOfKeyValueStoresResponse.model_validate(data).data
 
     async def get_or_create(
         self,

src/apify_client/_resource_clients/request_queue_collection.py

@@ -1,12 +1,15 @@
 from __future__ import annotations
 
-from typing import TYPE_CHECKING, Any
-
-from apify_client._models import CreateRequestQueueResponse, RequestQueue, RequestQueueShort
+from typing import Any
+
+from apify_client._models import (
+    CreateRequestQueueResponse,
+    GetListOfRequestQueuesResponse,
+    ListOfRequestQueues,
+    RequestQueue,
+)
 from apify_client._resource_clients.base import ResourceCollectionClient, ResourceCollectionClientAsync
-
-if TYPE_CHECKING:
-    from apify_client._types import ListPage
+from apify_client._utils import response_to_dict
 
 
 class RequestQueueCollectionClient(ResourceCollectionClient):
@@ -23,7 +26,7 @@ def list(
         limit: int | None = None,
         offset: int | None = None,
         desc: bool | None = None,
-    ) -> ListPage[RequestQueueShort]:
+    ) -> ListOfRequestQueues:
         """List the available request queues.
 
         https://docs.apify.com/api/v2#/reference/request-queues/queue-collection/get-list-of-request-queues
@@ -37,7 +40,13 @@ def list(
         Returns:
             The list of available request queues matching the specified filters.
         """
-        return self._list(unnamed=unnamed, limit=limit, offset=offset, desc=desc)
+        response = self.http_client.call(
+            url=self._url(),
+            method='GET',
+            params=self._params(unnamed=unnamed, limit=limit, offset=offset, desc=desc),
+        )
+        data = response_to_dict(response)
+        return GetListOfRequestQueuesResponse.model_validate(data).data
 
     def get_or_create(self, *, name: str | None = None) -> RequestQueue:
         """Retrieve a named request queue, or create a new one when it doesn't exist.
@@ -68,7 +77,7 @@ async def list(
         limit: int | None = None,
         offset: int | None = None,
         desc: bool | None = None,
-    ) -> ListPage[RequestQueueShort]:
+    ) -> ListOfRequestQueues:
         """List the available request queues.
 
         https://docs.apify.com/api/v2#/reference/request-queues/queue-collection/get-list-of-request-queues
@@ -82,7 +91,13 @@ async def list(
         Returns:
             The list of available request queues matching the specified filters.
         """
-        return await self._list(unnamed=unnamed, limit=limit, offset=offset, desc=desc)
+        response = await self.http_client.call(
+            url=self._url(),
+            method='GET',
+            params=self._params(unnamed=unnamed, limit=limit, offset=offset, desc=desc),
+        )
+        data = response_to_dict(response)
+        return GetListOfRequestQueuesResponse.model_validate(data).data
 
     async def get_or_create(self, *, name: str | None = None) -> RequestQueue:
         """Retrieve a named request queue, or create a new one when it doesn't exist.

src/apify_client/_resource_clients/run.py

@@ -107,7 +107,7 @@ def abort(self, *, gracefully: bool | None = None) -> Run:
             The data of the aborted Actor run.
         """
         response = self._abort(gracefully=gracefully)
-        return Run.model_validate(response)
+        return RunResponse.model_validate(response).data
 
     def wait_for_finish(self, *, wait_secs: int | None = None) -> Run | None:
         """Wait synchronously until the run finishes or the server times out.