New client commit

Author: vdusek

src/apify/storage_clients/_apify/_request_queue_shared_client.py

@@ -65,7 +65,7 @@ def __init__(
         """The Apify API client for communication with Apify platform."""
 
         self._queue_head = deque[str]()
-        """Local cache of request IDs from the queue head for efficient fetching."""
+        """Local cache of request IDs from the request queue head for efficient fetching."""
 
         self._requests_cache: LRUCache[str, CachedRequest] = LRUCache(maxsize=cache_size)
         """LRU cache storing request objects, keyed by request ID."""
@@ -176,7 +176,7 @@ async def fetch_next_request(self) -> Request | None:
             if not self._queue_head:
                 return None
 
-            # Get the next request ID from the queue head
+            # Get the next request ID from the request queue head
             next_request_id = self._queue_head.popleft()
 
         request = await self._get_or_hydrate_request(next_request_id)

tests/integration/apify_api/test_request_queue.py

@@ -8,7 +8,7 @@
 
 import pytest
 
-from apify_client._models import BatchOperationResult, UnprocessedRequest
+from apify_client._models import BatchAddResult, RequestDraft
 from apify_shared.consts import ApifyEnvVars
 from crawlee import service_locator
 from crawlee.crawlers import BasicCrawler
@@ -1169,18 +1169,18 @@ async def test_request_queue_deduplication_unprocessed_requests(
     assert stats_before is not None
     assert stats_before.write_count is not None
 
-    def return_unprocessed_requests(requests: list[dict], *_: Any, **__: Any) -> BatchOperationResult:
+    def return_unprocessed_requests(requests: list[dict], *_: Any, **__: Any) -> BatchAddResult:
         """Simulate API returning unprocessed requests."""
         unprocessed_requests = [
-            UnprocessedRequest.model_construct(
+            RequestDraft.model_construct(
                 url=request['url'],
                 unique_key=request['uniqueKey'],
                 method=request['method'],
             )
             for request in requests
         ]
 
-        return BatchOperationResult.model_construct(
+        return BatchAddResult.model_construct(
             processed_requests=[],
             unprocessed_requests=unprocessed_requests,
         )