joaquinclearmetal

def set_up_dag_run(context, dag_run_obj):
    dag_run_obj.payload = {"config": context["config"]}
    dag_run_obj.run_id = str(uuid4())
    print context
    return dag_run_obj
    
def launch_workflow_command(args):

    config_location = args.config_location
    analysis_id = args.analysis_id