clean up errback
This commit is contained in:
parent
2294e6bf36
commit
96c4837cb8
1 changed files with 4 additions and 4 deletions
|
@ -39,12 +39,12 @@ def _reflect_if_unavailable(reflector_has_stream, lbry_file, reflector_server):
|
||||||
return _reflect_stream(lbry_file, reflector_server)
|
return _reflect_stream(lbry_file, reflector_server)
|
||||||
|
|
||||||
|
|
||||||
def _catch_error(err):
|
def _catch_error(err, uri):
|
||||||
log.error(err.getTraceback())
|
log.error("An error occurred while checking availability for lbry://%s : %s", uri, err.message)
|
||||||
|
|
||||||
|
|
||||||
def check_and_restore_availability(lbry_file, reflector_server):
|
def check_and_restore_availability(lbry_file, reflector_server):
|
||||||
d = _check_if_reflector_has_stream(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.addCallbacks(lambda send_stream: _reflect_if_unavailable(send_stream, lbry_file, reflector_server),
|
||||||
d.addErrback(_catch_error)
|
lambda err: _catch_error(err, lbry_file.uri))
|
||||||
return d
|
return d
|
||||||
|
|
Loading…
Add table
Reference in a new issue