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