Madiator2011/lbry-sdk
1
0
Fork 0
forked from LBRYCommunity/lbry-sdk
Code Pull requests Activity

do not consume errors on DeferredList

Browse source
This commit is contained in:
Victor Shyba 2018-07-30 13:09:39 -03:00
parent 94a31922f7
commit 9742da348b
1 changed files with 4 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

6
lbrynet/core/HTTPBlobDownloader.py
View file

@ -49,9 +49,11 @@ class HTTPBlobDownloader(object):
for blob_hash in self.blob_hashes: for blob_hash in self.blob_hashes:
blob = yield self.blob_manager.get_blob(blob_hash) blob = yield self.blob_manager.get_blob(blob_hash)
if not blob.verified: 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 self.deferreds = dl
yield defer.DeferredList(dl, consumeErrors=True) yield defer.DeferredList(dl)
@defer.inlineCallbacks @defer.inlineCallbacks
def download_blob(self, blob): def download_blob(self, blob):