INNER CODE UNIT · Python

schedule_thread_worker

faucetsdn/poseidon · lib/poseidon_core/poseidon_core/main.py:35

def schedule_thread_worker(logger, scheduler=schedule):
    """schedule thread, takes care of running processes in the future"""
    logger.debug("Starting thread_worker")
    while True:
        sys.stdout.flush()
        scheduler.run_pending()
        time.sleep(1)


def main():  # pragma: no cover
    logging.getLogger("pika").setLevel(logging.CRITICAL)
    Logger()
    logger = logging.getLogger("main")
    config = Config().get_config()
    prom = start_prometheus(logger)

    # TODO option that doesn't require an sdn connection?
    sdnc = SDNConnect(

View source record →