make sure the downloader always stops gracefully

lbryio · Nov 3, 2021 · c0b8bdc · c0b8bdc
1 parent e1112db
commit c0b8bdc
Showing 1 changed file with 4 additions and 4 deletions.
diff --git a/lbry/stream/background_downloader.py b/lbry/stream/background_downloader.py
@@ -14,9 +14,9 @@ async def download_blobs(self, sd_hash):
         downloader = StreamDownloader(asyncio.get_running_loop(), self.conf, self.blob_manager, sd_hash)
         try:
             await downloader.start(self.node, save_stream=False)
+            for blob_info in downloader.descriptor.blobs[:-1]:
+                await downloader.download_stream_blob(blob_info)
         except ValueError:
             return
-        for blob_info in downloader.descriptor.blobs[:-1]:
-            await downloader.download_stream_blob(blob_info)
-        # for now, announcing is unnecessary because the blobs we have were announced to us, se they will be queried
-        # await self.storage.set_announce(sd_hash, downloader.descriptor.blobs[0].blob_hash)
+        finally:
+            downloader.stop()