File tree Expand file tree Collapse file tree 2 files changed +4
-16
lines changed
src/apify/apify_storage_client Expand file tree Collapse file tree 2 files changed +4
-16
lines changed Original file line number Diff line number Diff line change @@ -46,7 +46,7 @@ keywords = [
46
46
# https://github.com/apify/apify-sdk-python/pull/154.
47
47
[tool .poetry .dependencies ]
48
48
python = " ^3.9"
49
- apify-client = " >=1.7 .1"
49
+ apify-client = " >=1.8 .1"
50
50
apify-shared = " >=1.1.2"
51
51
crawlee = " >=0.3.5"
52
52
cryptography = " >=42.0.0"
Original file line number Diff line number Diff line change 2
2
3
3
from typing import TYPE_CHECKING
4
4
5
- from more_itertools import chunked
6
5
from typing_extensions import override
7
6
8
7
from crawlee import Request
@@ -158,11 +157,8 @@ async def batch_add_requests(
158
157
* ,
159
158
forefront : bool = False ,
160
159
) -> BatchRequestsOperationResponse :
161
- processed = []
162
- unprocessed = []
163
-
164
- for chunk in chunked (requests , 25 ): # The API endpoint won't accept more than 25 requests at once
165
- response = await self ._client .batch_add_requests (
160
+ return BatchRequestsOperationResponse .model_validate (
161
+ await self ._client .batch_add_requests (
166
162
requests = [
167
163
r .model_dump (
168
164
by_alias = True ,
@@ -174,18 +170,10 @@ async def batch_add_requests(
174
170
'data' ,
175
171
},
176
172
)
177
- for r in chunk
173
+ for r in requests
178
174
],
179
175
forefront = forefront ,
180
176
)
181
- processed .extend (response ['processedRequests' ])
182
- unprocessed .extend (response ['unprocessedRequests' ])
183
-
184
- return BatchRequestsOperationResponse .model_validate (
185
- {
186
- 'processedRequests' : processed ,
187
- 'unprocessedRequests' : unprocessed ,
188
- }
189
177
)
190
178
191
179
@override
You can’t perform that action at this time.
0 commit comments