runapp.py 文件源码

def restart_workflow(args, outdir):
    with open(args.inputfile, 'r') as infile:
        runner = dill.load(infile)

    if isinstance(runner.engine, pyccc.Docker) and runner.engine.client is None:
        runner.engine.client = runner.engine.connect_to_docker()

    engine, RunnerClass = get_execution_env(args)
    assert RunnerClass is runner.__class__

    if args.setoutput:
        set_ui_outputs(runner, args)

    print ' ----   RESTARTING WORKFLOW "%s"   ----\n' % runner.workflow.name

    run_workflow(runner, outdir)
    if args.dumptasks:
        dump_all_tasks(runner, outdir)