LBRYCommunity/lbry-sdk
1
0
Fork 1
Code Issues Pull requests Projects Releases 282 Packages Wiki Activity

remove unnecessary except/raise

Browse source
This commit is contained in:
Jack Robison 2019-04-18 17:07:55 -04:00
parent 35479dcbd2
commit e2663f6d57
No known key found for this signature in database
GPG key ID: DF25C68FE0239BB2
1 changed files with 0 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

4
lbrynet/blob_exchange/downloader.py
View file

@ -1,7 +1,6 @@
import asyncio import asyncio
import typing import typing
import logging import logging
import concurrent.futures
from lbrynet.utils import drain_tasks, cache_concurrent from lbrynet.utils import drain_tasks, cache_concurrent
from lbrynet.blob_exchange.client import request_blob from lbrynet.blob_exchange.client import request_blob
if typing.TYPE_CHECKING: if typing.TYPE_CHECKING:
@ -126,8 +125,6 @@ class BlobDownloader:
blob.close() blob.close()
log.debug("downloaded %s", blob_hash[:8]) log.debug("downloaded %s", blob_hash[:8])
return blob return blob
except (concurrent.futures.CancelledError, asyncio.CancelledError) as err:
error = err
finally: finally:
re_add = set() re_add = set()
while self.active_connections: while self.active_connections:
@ -138,7 +135,6 @@ class BlobDownloader:
if re_add: if re_add:
self.peer_queue.put_nowait(list(re_add)) self.peer_queue.put_nowait(list(re_add))
blob.close() blob.close()
raise error
def close(self): def close(self):
self.scores.clear() self.scores.clear()