diff --git a/lbrynet/reflector/client/client.py b/lbrynet/reflector/client/client.py index 3f855af90..5c8516633 100644 --- a/lbrynet/reflector/client/client.py +++ b/lbrynet/reflector/client/client.py @@ -99,7 +99,7 @@ class EncryptedFileReflectorClient(Protocol): log.debug('Finished sending data via reflector') self.factory.finished_deferred.callback(True) else: - log.debug('reflector finished: %s', reason) + log.debug('Reflector finished: %s', reason) self.factory.finished_deferred.callback(reason) # IConsumer stuff diff --git a/lbrynet/reflector/reupload.py b/lbrynet/reflector/reupload.py index 97e401c6c..df1be0b41 100644 --- a/lbrynet/reflector/reupload.py +++ b/lbrynet/reflector/reupload.py @@ -39,7 +39,12 @@ def _reflect_if_unavailable(reflector_has_stream, lbry_file, reflector_server): return _reflect_stream(lbry_file, reflector_server) +def _catch_error(err): + log.error(err.getTraceback()) + + def check_and_restore_availability(lbry_file, reflector_server): d = _check_if_reflector_has_stream(lbry_file, reflector_server) d.addCallback(lambda send_stream: _reflect_if_unavailable(send_stream, lbry_file, reflector_server)) + d.addErrback(_catch_error) return d