Fix

Author: vdusek

src/apify/storage_clients/_apify/_key_value_store_client.py

@@ -11,7 +11,7 @@
 from crawlee.storage_clients.models import KeyValueStoreRecord, KeyValueStoreRecordMetadata
 
 from ._api_client_creation import create_storage_api_client
-from ._models import ApifyKeyValueStoreMetadata, KeyValueStoreListKeysPage
+from ._models import ApifyKeyValueStoreMetadata
 
 if TYPE_CHECKING:
     from collections.abc import AsyncIterator
@@ -143,14 +143,13 @@ async def iterate_keys(
         count = 0
 
         while True:
-            response = await self._api_client.list_keys(exclusive_start_key=exclusive_start_key)
-            list_key_page = KeyValueStoreListKeysPage.model_validate(response)
+            list_key_page = await self._api_client.list_keys(exclusive_start_key=exclusive_start_key)
 
             for item in list_key_page.items:
                 # Convert KeyValueStoreKeyInfo to KeyValueStoreRecordMetadata
                 record_metadata = KeyValueStoreRecordMetadata(
                     key=item.key,
-                    size=item.size,
+                    size=int(item.size),
                     content_type='application/octet-stream',  # Content type not available from list_keys
                 )
                 yield record_metadata

src/apify/storage_clients/_apify/_request_queue_shared_client.py

@@ -442,7 +442,7 @@ async def _list_head(
         self.metadata.had_multiple_clients = list_and_lost_data.had_multiple_clients
 
         for request_data in list_and_lost_data.items:
-            request = Request.model_validate(request_data)
+            request = Request.model_validate(request_data.model_dump(by_alias=True))
             request_id = request_data.id
 
             # Skip requests without ID or unique key

src/apify/storage_clients/_apify/_request_queue_single_client.py

@@ -297,7 +297,7 @@ async def _list_head(self) -> None:
 
         # Update the cached data
         for request_data in response.items:
-            request = Request.model_validate(request_data)
+            request = Request.model_validate(request_data.model_dump(by_alias=True))
             request_id = request_data.id
 
             if request_id in self._requests_in_progress:
@@ -380,7 +380,7 @@ async def _init_caches(self) -> None:
         """
         response = await self._api_client.list_requests(limit=10_000)
         for request_data in response.items:
-            request = Request.model_validate(request_data)
+            request = Request.model_validate(request_data.model_dump(by_alias=True))
             request_id = request_data.id
 
             if request.was_already_handled: