diff --git a/lbrynet/blob_exchange/client.py b/lbrynet/blob_exchange/client.py index 05e0d9d9d..b77bbce28 100644 --- a/lbrynet/blob_exchange/client.py +++ b/lbrynet/blob_exchange/client.py @@ -105,8 +105,8 @@ class BlobExchangeClientProtocol(asyncio.Protocol): log.debug(msg) msg = f"downloaded {self.blob.blob_hash[:8]} from {self.peer_address}:{self.peer_port}" await asyncio.wait_for(self.writer.finished, self.peer_timeout, loop=self.loop) - await self.blob.finished_writing.wait() log.info(msg) + await self.blob.finished_writing.wait() return True, True except asyncio.CancelledError: return False, True diff --git a/lbrynet/blob_exchange/downloader.py b/lbrynet/blob_exchange/downloader.py index c034e6d13..ada08c471 100644 --- a/lbrynet/blob_exchange/downloader.py +++ b/lbrynet/blob_exchange/downloader.py @@ -87,7 +87,7 @@ class BlobDownloader: if task and not task.done(): task.cancel() await blob.close() - log.info("downloaded %s", blob_hash[:8]) + log.debug("downloaded %s", blob_hash[:8]) return blob except asyncio.CancelledError: while self.active_connections: