Do not cache individual loads if the entire batch dispatch fails, but still reject each request so they do not hang.
(loader, queue, error)
| 271 | |
| 272 | |
| 273 | def failed_dispatch(loader, queue, error): |
| 274 | """ |
| 275 | Do not cache individual loads if the entire batch dispatch fails, |
| 276 | but still reject each request so they do not hang. |
| 277 | """ |
| 278 | for loaded in queue: |
| 279 | loader.clear(loaded.key) |
| 280 | loaded.future.set_exception(error) |
no test coverage detected