(request)
| 22 | |
| 23 | |
| 24 | async def _mocked_download_func(request): |
| 25 | assert request.callback is NO_CALLBACK |
| 26 | response = request.meta.get("response") |
| 27 | if callable(response): |
| 28 | response = await response() |
| 29 | if isinstance(response, Exception): |
| 30 | raise response |
| 31 | return response |
| 32 | |
| 33 | |
| 34 | class UserDefinedPipeline(MediaPipeline): |