def _onStopFailed(self, reason): self.running = False raise Exception('Could not stop reactor: %s' % reason)