diff --git a/lbry/torrent/torrent_manager.py b/lbry/torrent/torrent_manager.py
index fc29bb7946..35e59f5a12 100644
--- a/lbry/torrent/torrent_manager.py
+++ b/lbry/torrent/torrent_manager.py
@@ -170,6 +170,7 @@ async def _load_stream(self, rowid: int, bt_infohash: str, file_name: Optional[s
             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():