from garcon import activity

from ingest_training import config
from ingest_training import flow

ingest_training_flow = flow.IngestTrainingFlow(
    config.env, 
    config.version)

worker = activity.ActivityWorker(ingest_training_flow)
worker.run()