run.py 2.67 KB
Newer Older
1
2
3
4
import argparse
import sys
import os
import importlib
5
import pickle
6
import modes.experiments as exp
7
import modes.runtime as runtime
8
9
10
11
12

def mkdir_if_not_exists(path):
    if not os.path.exists(path):
        os.mkdir(path)

13

14
15
16
17
parser = argparse.ArgumentParser()
parser.add_argument('experiments', metavar='EXP', type=str, nargs='+',
        help='An experiment file to run')
parser.add_argument('--runs', metavar='N', type=int, default=1,
18
        help='Number of repetition for each experiment')
19
20
21
parser.add_argument('--verbose', action='store_const', const=True,
        default=False,
        help='Verbose output')
22
23
24

g_env = parser.add_argument_group('Environment')
g_env.add_argument('--repo', metavar='DIR', type=str,
25
        default='..', help='Repo directory')
26
g_env.add_argument('--workdir', metavar='DIR', type=str,
27
        default='./out/', help='Work directory base')
28
g_env.add_argument('--outdir', metavar='DIR',  type=str,
29
30
        default='./out/', help='Output directory base')

31
32
33
34
35
36
37
38
39
40
g_par = parser.add_argument_group('Parallel Runtime')
g_par.add_argument('--parallel', dest='runtime', action='store_const',
        const='parallel', default='sequential',
        help='Use parallel instead of sequential runtime')
g_par.add_argument('--cores', metavar='N', type=int,
        default=len(os.sched_getaffinity(0)),
        help='Number of cores to use for parallel runs')
g_par.add_argument('--mem', metavar='N', type=int, default=None,
        help='Memory limit for parallel runs (in MB)')

41
42
43
44
args = parser.parse_args()

experiments = []
for path in args.experiments:
45
46
47
48
49
50
51
52
53
54
    modname, modext = os.path.splitext(os.path.basename(path))

    if modext == '.py':
        spec = importlib.util.spec_from_file_location(modname, path)
        mod = importlib.util.module_from_spec(spec)
        spec.loader.exec_module(mod)
        experiments += mod.experiments
    else:
        with open(path, 'rb') as f:
            experiments.append(pickle.load(f))
55
56
57
58

mkdir_if_not_exists(args.workdir)
mkdir_if_not_exists(args.outdir)

59
if args.runtime == 'parallel':
60
61
    rt = runtime.LocalParallelRuntime(cores=args.cores, mem=args.mem,
            verbose=args.verbose)
62
else:
63
    rt = runtime.LocalSimpleRuntime(verbose=args.verbose)
64

65
66
67
68
69
70
71
72
73
74
75
76
77
78
for e in experiments:
    workdir_base = '%s/%s' % (args.workdir, e.name)
    mkdir_if_not_exists(workdir_base)

    for run in range(0, args.runs):
        outpath = '%s/%s-%d.json' % (args.outdir, e.name, run)
        if os.path.exists(outpath):
            print('skip %s run %d' % (e.name, run))
            continue

        workdir = '%s/%d' % (workdir_base, run)
        mkdir_if_not_exists(workdir)

        env = exp.ExpEnv(args.repo, workdir)
79
        rt.add_run(runtime.Run(e, env, outpath))
80

81
rt.start()