import time from garcon import decider from ingest_training import config from ingest_training import flow ingest_training_flow = flow.IngestTrainingFlow( config.env, config.version) decider_worker = decider.DeciderWorker(ingest_training_flow) while(True): decider_worker.run() time.sleep(1)