Fix

Author: vdusek

src/apify_client/_models.py

@@ -1,6 +1,6 @@
 # generated by datamodel-codegen:
 #   filename:  openapi.json
-#   timestamp: 2025-12-26T10:24:32+00:00
+#   timestamp: 2025-12-26T10:41:32+00:00
 
 from __future__ import annotations
 

src/apify_client/_resource_clients/request_queue.py

@@ -302,7 +302,7 @@ def batch_add_requests(
         max_parallel: int = 1,
         max_unprocessed_requests_retries: int | None = None,
         min_delay_between_unprocessed_requests_retries: timedelta | None = None,
-    ) -> BatchOperationResponse:
+    ) -> Data13:
         """Add requests to the request queue in batches.
 
         Requests are split into batches based on size and processed in parallel.
@@ -373,7 +373,7 @@ def batch_add_requests(
                 processed_requests=processed_requests,
                 unprocessed_requests=unprocessed_requests,
             )
-        )
+        ).data
 
     def batch_delete_requests(self, requests: list[dict]) -> Data13:
         """Delete given requests from the queue.
@@ -751,7 +751,7 @@ async def batch_add_requests(
         max_parallel: int = 5,
         max_unprocessed_requests_retries: int | None = None,
         min_delay_between_unprocessed_requests_retries: timedelta | None = None,
-    ) -> BatchOperationResponse:
+    ) -> Data13:
         """Add requests to the request queue in batches.
 
         Requests are split into batches based on size and processed in parallel.
@@ -823,7 +823,7 @@ async def batch_add_requests(
                 processed_requests=processed_requests,
                 unprocessed_requests=unprocessed_requests,
             )
-        )
+        ).data
 
     async def batch_delete_requests(self, requests: list[dict]) -> Data13:
         """Delete given requests from the queue.

tests/integration/test_request_queue.py

@@ -238,9 +238,8 @@ def test_request_queue_batch_add_requests(apify_client: ApifyClient) -> None:
     requests_to_add = [{'url': f'https://example.com/batch-{i}', 'uniqueKey': f'batch-{i}'} for i in range(10)]
     batch_response = queue_client.batch_add_requests(requests_to_add)
     assert batch_response is not None
-    assert batch_response.data is not None
-    assert len(batch_response.data.processed_requests) == 10
-    assert len(batch_response.data.unprocessed_requests) == 0
+    assert len(batch_response.processed_requests) == 10
+    assert len(batch_response.unprocessed_requests) == 0
 
     # Wait briefly for eventual consistency
     time.sleep(1)

tests/integration/test_request_queue_async.py

@@ -238,9 +238,8 @@ async def test_request_queue_batch_add_requests(apify_client_async: ApifyClientA
     requests_to_add = [{'url': f'https://example.com/batch-{i}', 'uniqueKey': f'batch-{i}'} for i in range(10)]
     batch_response = await queue_client.batch_add_requests(requests_to_add)
     assert batch_response is not None
-    assert batch_response.data is not None
-    assert len(batch_response.data.processed_requests) == 10
-    assert len(batch_response.data.unprocessed_requests) == 0
+    assert len(batch_response.processed_requests) == 10
+    assert len(batch_response.unprocessed_requests) == 0
 
     # Wait briefly for eventual consistency
     await asyncio.sleep(1)

tests/unit/test_client_request_queue.py

@@ -61,9 +61,9 @@ async def test_batch_processed_partially_async(httpserver: HTTPServer) -> None:
     rq_client = client.request_queue(request_queue_id='whatever')
 
     batch_response = await rq_client.batch_add_requests(requests=requests)
-    assert requests[0]['uniqueKey'] in {request.unique_key for request in batch_response.data.processed_requests}
-    assert len(batch_response.data.unprocessed_requests) == 1
-    assert batch_response.data.unprocessed_requests[0].unique_key == requests[1]['uniqueKey']
+    assert requests[0]['uniqueKey'] in {request.unique_key for request in batch_response.processed_requests}
+    assert len(batch_response.unprocessed_requests) == 1
+    assert batch_response.unprocessed_requests[0].unique_key == requests[1]['uniqueKey']
 
 
 @pytest.mark.usefixtures('patch_basic_url')
@@ -96,6 +96,6 @@ async def test_batch_processed_partially_sync(httpserver: HTTPServer) -> None:
     rq_client = client.request_queue(request_queue_id='whatever')
 
     batch_response = rq_client.batch_add_requests(requests=requests)
-    assert requests[0]['uniqueKey'] in {request.unique_key for request in batch_response.data.processed_requests}
-    assert len(batch_response.data.unprocessed_requests) == 1
-    assert batch_response.data.unprocessed_requests[0].unique_key == requests[1]['uniqueKey']
+    assert requests[0]['uniqueKey'] in {request.unique_key for request in batch_response.processed_requests}
+    assert len(batch_response.unprocessed_requests) == 1
+    assert batch_response.unprocessed_requests[0].unique_key == requests[1]['uniqueKey']