def run(self):
    logging.info('Running reactor...')
    self.__called_later = reactor.callLater(0, self.probe_all_logs)
    reactor.run(installSignalHandlers=0)
    logging.info('Reactor no longer running.')
def run(self):
    logging.info('Running reactor...')
    self.__called_later = reactor.callLater(0, self.probe_all_logs)
    reactor.run(installSignalHandlers=0)
    logging.info('Reactor no longer running.')