from garcon import activity
import boto.swf.layer2 as swf

from ingest_training import config
from ingest_training import flow

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

execution = swf.WorkflowType(
    name=ingest_training_flow.name,
    domain=ingest_training_flow.domain,
    version=ingest_training_flow.version,
    task_list=ingest_training_flow.name).start()