From 0a027cf2dea2543584e731664f97537a288048de Mon Sep 17 00:00:00 2001 From: Jack Robison Date: Sun, 3 Feb 2019 15:43:25 -0500 Subject: [PATCH] logging --- lbrynet/stream/stream_manager.py | 4 +--- 1 file changed, 1 insertion(+), 3 deletions(-) diff --git a/lbrynet/stream/stream_manager.py b/lbrynet/stream/stream_manager.py index a29976e39..8374ac705 100644 --- a/lbrynet/stream/stream_manager.py +++ b/lbrynet/stream/stream_manager.py @@ -135,6 +135,7 @@ class StreamManager: binascii.unhexlify(file_info['download_directory']).decode(), file_info['status'], file_info['claim'] ) for file_info in file_infos ]) + log.info("Started stream manager with %i files", len(file_infos)) async def resume(self): if not self.node: @@ -153,7 +154,6 @@ class StreamManager: sd_hashes = await self.storage.get_streams_to_re_reflect() streams = list(filter(lambda s: s.sd_hash in sd_hashes, self.streams)) batch = [] - total = len(streams) while streams: stream = streams.pop() if not stream.fully_reflected.is_set(): @@ -164,8 +164,6 @@ class StreamManager: batch = [] if batch: await asyncio.gather(*batch) - if total: - log.info("uploaded %i streams to reflector", total) await asyncio.sleep(300, loop=self.loop) async def start(self):