projects
/
arvados.git
/ commitdiff
summary
|
shortlog
|
log
|
commit
| commitdiff |
tree
raw
|
patch
|
inline
| side by side (parent:
7d6c76b
)
run job tasks in qsequence order in first pass
author
Tom Clegg <tom@clinicalfuture.com>
Tue, 4 Jun 2013 16:42:48 +0000
(12:42 -0400)
committer
Tom Clegg <tom@clinicalfuture.com>
Tue, 4 Jun 2013 16:42:48 +0000
(12:42 -0400)
services/crunch/crunch-job
patch
|
blob
|
history
diff --git
a/services/crunch/crunch-job
b/services/crunch/crunch-job
index c8c5908ef864fbfa5e747724c783d4ba80386590..29ee98d355e1194508ce421e6df30649cd462654 100755
(executable)
--- a/
services/crunch/crunch-job
+++ b/
services/crunch/crunch-job
@@
-791,9
+791,12
@@
sub reapchildren
delete $proc{$pid};
# Load new tasks
delete $proc{$pid};
# Load new tasks
- my $newtask_list = $arv->{'job_tasks'}->{'list'}->execute('where' => {
- 'created_by_job_task' => $Jobstep->{arvados_task}->{uuid}
- });
+ my $newtask_list = $arv->{'job_tasks'}->{'list'}->execute(
+ 'where' => {
+ 'created_by_job_task' => $Jobstep->{arvados_task}->{uuid}
+ },
+ 'order' => 'qsequence'
+ );
foreach my $arvados_task (@{$newtask_list->{'items'}}) {
my $jobstep = {
'level' => $arvados_task->{'sequence'},
foreach my $arvados_task (@{$newtask_list->{'items'}}) {
my $jobstep = {
'level' => $arvados_task->{'sequence'},