Nucypher
/
nucypher
mirror of https://github.com/nucypher/nucypher.git
1
0
Fork 0
Code Issues Projects Releases Wiki Activity

Errors in the learning loop are now raised on the main thread in tests.

pull/329/head
jMyles 2018-06-29 17:59:29 -07:00
parent 36d85d5a02
commit df9f7b77fa
1 changed files with 11 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
nucypher/characters.py
View File

@ -234,11 +234,19 @@ class Character:
self._node_ids_to_learn_about_immediately.discard(address)
def start_learning(self):
d = self._learning_task.start(interval=self._SECONDS_DELAY_BETWEEN_LEARNING, now=True)
d.addErrback(self.handle_learning_errors)
if self._learning_task.running:
return False
else:
d = self._learning_task.start(interval=self._SECONDS_DELAY_BETWEEN_LEARNING, now=True)
d.addErrback(self.handle_learning_errors)
return d
def handle_learning_errors(self, *args, **kwargs):
self.log.warning("Unhandled error during node learning: {}".format(args))
failure = args[0]
if self._abort_on_learning_error:
failure.raiseException()
else:
self.log.warning("Unhandled error during node learning: {}".format(failure.getTraceback()))
def shuffled_known_nodes(self):
nodes_we_know_about = list(self._known_nodes.values())