fix hanging streamprogressmanager

This commit is contained in:
Jack Robison 2017-09-07 11:55:41 -04:00
parent 632fd764fa
commit cfe73a8627
No known key found for this signature in database
GPG key ID: 284699E7404E3CFF

View file

@ -154,10 +154,11 @@ class FullStreamProgressManager(StreamProgressManager):
d.addCallback(lambda _: check_if_finished())
def log_error(err):
log.warning("Error occurred in the output loop. Error: %s", err.getErrorMessage())
log.warning("Error occurred in the output loop. Error: %s", err)
if self.outputting_d is not None and not self.outputting_d.called:
self.outputting_d.callback(True)
self.outputting_d = None
self.stop()
d.addErrback(log_error)
else: