From 9742da348b220d1fb6c0ff394d463c02bbf9441f Mon Sep 17 00:00:00 2001 From: Victor Shyba Date: Mon, 30 Jul 2018 13:09:39 -0300 Subject: [PATCH] do not consume errors on DeferredList --- lbrynet/core/HTTPBlobDownloader.py | 6 ++++-- 1 file changed, 4 insertions(+), 2 deletions(-) diff --git a/lbrynet/core/HTTPBlobDownloader.py b/lbrynet/core/HTTPBlobDownloader.py index 72fa3de63..cf616d16b 100644 --- a/lbrynet/core/HTTPBlobDownloader.py +++ b/lbrynet/core/HTTPBlobDownloader.py @@ -49,9 +49,11 @@ class HTTPBlobDownloader(object): for blob_hash in self.blob_hashes: blob = yield self.blob_manager.get_blob(blob_hash) if not blob.verified: - dl.append(self.semaphore.run(self.download_blob, blob)) + d = self.semaphore.run(self.download_blob, blob) + d.addErrback(lambda err: err.check(defer.TimeoutError, defer.CancelledError)) + dl.append(d) self.deferreds = dl - yield defer.DeferredList(dl, consumeErrors=True) + yield defer.DeferredList(dl) @defer.inlineCallbacks def download_blob(self, blob):