Commit 0c76d950 authored by Manuel Günther's avatar Manuel Günther
Browse files

Added --parallel command line option to the bin/ script (and all derived scripts).

parent e45cd27c
......@@ -165,7 +165,7 @@ def train_enroller(algorithm, extractor, force = False):
train_features = read_features(train_files, reader, True)
# perform training"- Enrollment: training enroller '%s' using %d identities: ", fs.enroller_file, len(train_features))"- Enrollment: training enroller '%s' using %d identities", fs.enroller_file, len(train_features))
algorithm.train_enroller(train_features, fs.enroller_file)
......@@ -131,6 +131,8 @@ def command_line_parser(description=__doc__, exclude_resources_from=[]):
help = 'Performs score calibration after the scores are computed.')
flag_group.add_argument('-z', '--zt-norm', action='store_true',
help = 'Enable the computation of ZT norms')
flag_group.add_argument('-r', '--parallel', type=int,
help = 'This flag is a shortcut for running the commands on the local machine with the given amount of parallel threads; equivalent to --grid"local", number_of_parallel_threads=X) --run-local-scheduler --stop-on-failure.')
return {
'main' : parser,
......@@ -191,6 +193,11 @@ def initialize(parsers, command_line_parameters = None, skips = []):
if skip not in args.execute_only:
exec("args.skip_%s = True" % (skip.replace("-", "_")))
if args.parallel is not None:
args.grid = ['"local", number_of_parallel_processes = %d)' % args.parallel]
args.run_local_scheduler = True
args.stop_on_failure = True
# logging
bob.core.log.set_verbosity_level(logger, args.verbose)
Markdown is supported
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment