diff --git a/lbrynet/conf.py b/lbrynet/conf.py index 68ce3dc8c..0e13577d8 100644 --- a/lbrynet/conf.py +++ b/lbrynet/conf.py @@ -485,7 +485,8 @@ class Config(CLIConfig): previous_names=['announce_head_blobs_only'] ) concurrent_blob_announcers = Integer( - "Number of blobs to iteratively announce at once", 10, previous_names=['concurrent_announcers'] + "Number of blobs to iteratively announce at once, set to 0 to disable", 10, + previous_names=['concurrent_announcers'] ) max_connections_per_download = Integer( "Maximum number of peers to connect to while downloading a blob", 5, diff --git a/lbrynet/dht/blob_announcer.py b/lbrynet/dht/blob_announcer.py index 2a209e65e..fa4d5cc06 100644 --- a/lbrynet/dht/blob_announcer.py +++ b/lbrynet/dht/blob_announcer.py @@ -19,6 +19,8 @@ class BlobAnnouncer: self.announce_queue: typing.List[str] = [] async def _announce(self, batch_size: typing.Optional[int] = 10): + if not batch_size: + return if not self.node.joined.is_set(): await self.node.joined.wait() blob_hashes = await self.storage.get_blobs_to_announce()