Skip to content
Snippets Groups Projects
Commit d8791209 authored by Amir Mohammadi's avatar Amir Mohammadi Committed by Amir MOHAMMADI
Browse files

score computation is not a parallel job

parent e318ac17
Branches
Tags v1.0.5
1 merge request!31Improvements
Pipeline #
...@@ -114,7 +114,6 @@ def add_jobs(args, submitter): ...@@ -114,7 +114,6 @@ def add_jobs(args, submitter):
**args.grid.projection_queue) **args.grid.projection_queue)
deps.append(job_ids['projection']) deps.append(job_ids['projection'])
concat_deps = {}
for group in args.groups: for group in args.groups:
# compute scores # compute scores
if not args.skip_score_computation: if not args.skip_score_computation:
...@@ -124,14 +123,8 @@ def add_jobs(args, submitter): ...@@ -124,14 +123,8 @@ def add_jobs(args, submitter):
job_ids['score-%s' % group] = submitter.submit( job_ids['score-%s' % group] = submitter.submit(
'--sub-task compute-scores --group %s' % group, '--sub-task compute-scores --group %s' % group,
name="score-%s" % group, name="score-%s" % group,
number_of_parallel_jobs=args.grid.number_of_scoring_jobs,
dependencies=deps, dependencies=deps,
**args.grid.scoring_queue) **args.grid.scoring_queue)
concat_deps[group] = [job_ids['score-%s' % group]]
else:
concat_deps[group] = []
if args.grid is None: if args.grid is None:
# return the list of jobs that need to be executed in series # return the list of jobs that need to be executed in series
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment