diff --git a/lbry/stream/managed_stream.py b/lbry/stream/managed_stream.py index e8e67b33c..3e615dfc6 100644 --- a/lbry/stream/managed_stream.py +++ b/lbry/stream/managed_stream.py @@ -354,20 +354,19 @@ class ManagedStream(ManagedDownloadSource): self.reflector_progress = int((i + 1) / len(we_have) * 100) except (asyncio.TimeoutError, ValueError): return sent - except ConnectionRefusedError: + except ConnectionError: return sent except (OSError, Exception) as err: if isinstance(err, asyncio.CancelledError): log.warning("stopped uploading %s#%s to reflector", self.claim_name, self.claim_id) - raise err - if isinstance(err, OSError): + elif isinstance(err, OSError): log.warning( "stopped uploading %s#%s to reflector because blobs were deleted or moved", self.claim_name, self.claim_id ) else: log.exception("unexpected error reflecting %s#%s", self.claim_name, self.claim_id) - raise asyncio.CancelledError() + return sent finally: if protocol.transport: protocol.transport.close() diff --git a/lbry/stream/stream_manager.py b/lbry/stream/stream_manager.py index 541f5cdf0..cc4684976 100644 --- a/lbry/stream/stream_manager.py +++ b/lbry/stream/stream_manager.py @@ -160,13 +160,13 @@ class StreamManager(SourceManager): async def reflect_streams(self): try: - return await self._reflact_streams() + return await self._reflect_streams() except asyncio.CancelledError: raise except Exception: log.exception("reflector task encountered an unexpected error!") - async def _reflact_streams(self): + async def _reflect_streams(self): # todo: those debug statements are temporary for #2987 - remove them if its closed while True: if self.config.reflect_streams and self.config.reflector_servers: