(
requests: Sequence[Request],
*,
forefront: bool = False,
)
| 273 | forefront_calls: list[bool] = [] |
| 274 | |
| 275 | async def patched_add_batch( |
| 276 | requests: Sequence[Request], |
| 277 | *, |
| 278 | forefront: bool = False, |
| 279 | ) -> AddRequestsResponse: |
| 280 | forefront_calls.append(forefront) |
| 281 | if len(forefront_calls) == 1: |
| 282 | return AddRequestsResponse( |
| 283 | processed_requests=[], |
| 284 | unprocessed_requests=[UnprocessedRequest(unique_key=r.unique_key, url=r.url) for r in requests], |
| 285 | ) |
| 286 | return AddRequestsResponse( |
| 287 | processed_requests=[ |
| 288 | ProcessedRequest( |
| 289 | unique_key=r.unique_key, |
| 290 | was_already_present=False, |
| 291 | was_already_handled=False, |
| 292 | ) |
| 293 | for r in requests |
| 294 | ], |
| 295 | unprocessed_requests=[], |
| 296 | ) |
| 297 | |
| 298 | monkeypatch.setattr(rq._client, 'add_batch_of_requests', patched_add_batch) |
| 299 |
nothing calls this directly
no test coverage detected