diff --git a/lbry/torrent/torrent_manager.py b/lbry/torrent/torrent_manager.py
index fc29bb794..35e59f5a1 100644
--- a/lbry/torrent/torrent_manager.py
+++ b/lbry/torrent/torrent_manager.py
@@ -170,6 +170,7 @@ class TorrentManager(SourceManager):
             torrent_session=self.torrent_session
         )
         self.add(stream)
+        await stream.start()
 
     async def initialize_from_database(self):
         for file in await self.storage.get_all_torrent_files():