(self)
| 236 | |
| 237 | @coroutine_test |
| 238 | async def test_result_failure(self): |
| 239 | self.pipe.LOG_FAILED_RESULTS = False |
| 240 | exc = Exception("foo") |
| 241 | req = Request( |
| 242 | "http://url1", |
| 243 | meta={"response": exc}, |
| 244 | errback=self._errback, |
| 245 | ) |
| 246 | item = {"requests": req} |
| 247 | new_item = await self.pipe.process_item(item) |
| 248 | assert len(new_item["results"]) == 1 |
| 249 | assert new_item["results"][0][0] is False |
| 250 | assert isinstance(new_item["results"][0][1], Failure) |
| 251 | assert new_item["results"][0][1].value == exc |
| 252 | assert self.pipe._mockcalled == [ |
| 253 | "get_media_requests", |
| 254 | "media_to_download", |
| 255 | "media_failed", |
| 256 | "request_errback", |
| 257 | "item_completed", |
| 258 | ] |
| 259 | |
| 260 | @coroutine_test |
| 261 | async def test_mix_of_success_and_failure(self): |
nothing calls this directly
no test coverage detected